Configure fuzzer as a standalone Go module and fix dependency issues

- Implement local CreatePodWithRetries to remove k8s.io/kubernetes dependency.
- Initialize go.mod with k8s.io v0.32.1 dependencies.
- Update README and CLI flags to reflect standalone directory structure.

Examples:

1. High-concurrency 50k pod injection:
   go run cmd/main.go --base-pod templates/complex-daemonset.yaml --namespace fuzz-test --name-prefix representative-pod --count 50000 --concurrency 100

2. Single fuzzed output pod for inspection:
   go run cmd/main.go --base-pod templates/complex-daemonset.yaml --count 1 --out-dir ./output-pod

Author: seans3

fuzzer/README.md

@@ -48,8 +48,8 @@ kubectl create serviceaccount cilium -n fuzz-test
 Inject the pods using high concurrency.
 
 ```bash
-go run test/utils/fuzzer/cmd/main.go \
-  --base-pod test/utils/fuzzer/templates/complex-daemonset.yaml \
+go run cmd/main.go \
+  --base-pod templates/complex-daemonset.yaml \
   --namespace fuzz-test \
   --name-prefix representative-pod \
   --count 50000 \
@@ -61,7 +61,7 @@ go run test/utils/fuzzer/cmd/main.go \
 ### Generate Pod Manifests to Disk
 To generate fuzzed manifests for manual inspection:
 ```bash
-go run test/utils/fuzzer/cmd/main.go \
+go run cmd/main.go \
   --base-pod path/to/real-pod.yaml \
   --name-prefix representative-pod \
   --namespace my-test-ns \

fuzzer/cmd/main.go

@@ -27,14 +27,14 @@ import (
 	v1 "k8s.io/api/core/v1"
 	"k8s.io/client-go/kubernetes"
 	"k8s.io/client-go/tools/clientcmd"
-	"k8s.io/kubernetes/test/utils/fuzzer"
+	"k8s.io/perf-tests/fuzzer"
 	"sigs.k8s.io/yaml"
 )
 
 func main() {
 	count := flag.Int("count", 1000, "Number of pods to generate")
 	offset := flag.Int("offset", 0, "Starting index for pod naming")
-	basePodPath := flag.String("base-pod", "test/utils/fuzzer/templates/complex-daemonset.yaml", "Path to the real pod YAML to sanitize and clone")
+	basePodPath := flag.String("base-pod", "templates/complex-daemonset.yaml", "Path to the real pod YAML to sanitize and clone")
 	namespace := flag.String("namespace", "fuzz-test", "Target namespace for fuzzed pods")
 	namePrefix := flag.String("name-prefix", "fuzzed-pod", "Prefix for generated pod names")
 	outDir := flag.String("out-dir", "", "Directory to write YAMLs (if specified, no cluster injection)")

fuzzer/fuzzer.go

@@ -26,16 +26,39 @@ import (
 	"strings"
 	"sync"
 	"sync/atomic"
+	"time"
 
 	"golang.org/x/sync/errgroup"
 	v1 "k8s.io/api/core/v1"
+	apierrors "k8s.io/apimachinery/pkg/api/errors"
 	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
 	"k8s.io/apimachinery/pkg/types"
+	"k8s.io/apimachinery/pkg/util/wait"
 	clientset "k8s.io/client-go/kubernetes"
-	"k8s.io/kubernetes/test/utils"
 	"sigs.k8s.io/yaml"
 )
 
+// CreatePodWithRetries creates a pod with exponential backoff retries on transient errors.
+func CreatePodWithRetries(c clientset.Interface, namespace string, obj *v1.Pod) error {
+	if obj == nil {
+		return fmt.Errorf("object provided to create is empty")
+	}
+	backoff := wait.Backoff{
+		Duration: 100 * time.Millisecond,
+		Factor:   3,
+		Steps:    6,
+	}
+	return wait.ExponentialBackoff(backoff, func() (bool, error) {
+		_, err := c.CoreV1().Pods(namespace).Create(context.TODO(), obj, metav1.CreateOptions{})
+		if err == nil || apierrors.IsAlreadyExists(err) {
+			return true, nil
+		}
+		// GenerateName conflict or other temporary issues can be retried if needed,
+		// but for the fuzzer we assume concrete names.
+		return false, fmt.Errorf("failed to create pod %s: %v", obj.Name, err)
+	})
+}
+
 // ExemplaryPodFuzzer generates fuzzed Pod objects derived from a base pod.
 type ExemplaryPodFuzzer struct {
 	rng *rand.Rand
@@ -221,7 +244,7 @@ func NewExemplaryPodCreator(client clientset.Interface, seed int64, namePrefix,
 // CreateExemplaryPods creates a batch of pods concurrently based on a base pod.
 func (c *ExemplaryPodCreator) CreateExemplaryPods(ctx context.Context, base *v1.Pod, count int, offset int, concurrency int, progress ProgressCallback) error {
 	return c.processExemplaryPods(ctx, base, count, offset, concurrency, progress, func(pod *v1.Pod) error {
-		return utils.CreatePodWithRetries(c.client, pod.Namespace, pod)
+		return CreatePodWithRetries(c.client, pod.Namespace, pod)
 	})
 }
 

fuzzer/fuzzer_test.go

@@ -108,7 +108,7 @@ func TestDeeplyNestedManagedFields(t *testing.T) {
 	assert.Len(t, pod.ManagedFields, 1)
 	assert.Equal(t, "kubelet", pod.ManagedFields[0].Manager)
 
-	raw := string(pod.ManagedFields[0].FieldsV1.GetRawBytes())
+	raw := string(pod.ManagedFields[0].FieldsV1.Raw)
 	// Verify it contains fuzzed field paths
 	assert.Contains(t, raw, "f:fuzzed_field_")
 	assert.Contains(t, raw, "k:{\\\"id\\\":")

fuzzer/go.mod

@@ -0,0 +1,89 @@
+module k8s.io/perf-tests/fuzzer
+
+go 1.25.0
+
+require (
+	github.com/stretchr/testify v1.10.0
+	golang.org/x/sync v0.10.0
+	k8s.io/api v0.32.1
+	k8s.io/apimachinery v0.32.1
+	k8s.io/client-go v0.32.1
+	sigs.k8s.io/yaml v1.4.0
+)
+
+require (
+	github.com/davecgh/go-spew v1.1.2-0.20180830191138-d8f796af33cc // indirect
+	github.com/emicklei/go-restful/v3 v3.11.0 // indirect
+	github.com/fxamacker/cbor/v2 v2.7.0 // indirect
+	github.com/go-logr/logr v1.4.2 // indirect
+	github.com/go-openapi/jsonpointer v0.21.0 // indirect
+	github.com/go-openapi/jsonreference v0.20.2 // indirect
+	github.com/go-openapi/swag v0.23.0 // indirect
+	github.com/gogo/protobuf v1.3.2 // indirect
+	github.com/golang/protobuf v1.5.4 // indirect
+	github.com/google/gnostic-models v0.6.8 // indirect
+	github.com/google/go-cmp v0.6.0 // indirect
+	github.com/google/gofuzz v1.2.0 // indirect
+	github.com/google/uuid v1.6.0 // indirect
+	github.com/josharian/intern v1.0.0 // indirect
+	github.com/json-iterator/go v1.1.12 // indirect
+	github.com/mailru/easyjson v0.7.7 // indirect
+	github.com/modern-go/concurrent v0.0.0-20180306012644-bacd9c7ef1dd // indirect
+	github.com/modern-go/reflect2 v1.0.2 // indirect
+	github.com/munnerz/goautoneg v0.0.0-20191010083416-a7dc8b61c822 // indirect
+	github.com/pkg/errors v0.9.1 // indirect
+	github.com/pmezard/go-difflib v1.0.1-0.20181226105442-5d4384ee4fb2 // indirect
+	github.com/spf13/pflag v1.0.5 // indirect
+	github.com/x448/float16 v0.8.4 // indirect
+	golang.org/x/net v0.30.0 // indirect
+	golang.org/x/oauth2 v0.23.0 // indirect
+	golang.org/x/sys v0.26.0 // indirect
+	golang.org/x/term v0.25.0 // indirect
+	golang.org/x/text v0.19.0 // indirect
+	golang.org/x/time v0.7.0 // indirect
+	google.golang.org/protobuf v1.35.1 // indirect
+	gopkg.in/evanphx/json-patch.v4 v4.12.0 // indirect
+	gopkg.in/inf.v0 v0.9.1 // indirect
+	gopkg.in/yaml.v3 v3.0.1 // indirect
+	k8s.io/klog/v2 v2.130.1 // indirect
+	k8s.io/kube-openapi v0.0.0-20241105132330-32ad38e42d3f // indirect
+	k8s.io/utils v0.0.0-20241104100929-3ea5e8cea738 // indirect
+	sigs.k8s.io/json v0.0.0-20241010143419-9aa6b5e7a4b3 // indirect
+	sigs.k8s.io/structured-merge-diff/v4 v4.4.2 // indirect
+)
+
+replace (
+	k8s.io/api => k8s.io/api v0.32.1
+	k8s.io/apiextensions-apiserver => k8s.io/apiextensions-apiserver v0.32.1
+	k8s.io/apimachinery => k8s.io/apimachinery v0.32.1
+	k8s.io/apiserver => k8s.io/apiserver v0.32.1
+	k8s.io/cli-runtime => k8s.io/cli-runtime v0.32.1
+	k8s.io/client-go => k8s.io/client-go v0.32.1
+	k8s.io/cloud-provider => k8s.io/cloud-provider v0.32.1
+	k8s.io/cluster-bootstrap => k8s.io/cluster-bootstrap v0.32.1
+	k8s.io/code-generator => k8s.io/code-generator v0.32.1
+	k8s.io/component-base => k8s.io/component-base v0.32.1
+	k8s.io/component-helpers => k8s.io/component-helpers v0.32.1
+	k8s.io/controller-manager => k8s.io/controller-manager v0.32.1
+	k8s.io/cri-api => k8s.io/cri-api v0.32.1
+	k8s.io/cri-control-plane => k8s.io/cri-control-plane v0.32.1
+	k8s.io/csi-translation-lib => k8s.io/csi-translation-lib v0.32.1
+	k8s.io/dynamic-resource-allocation => k8s.io/dynamic-resource-allocation v0.32.1
+	k8s.io/endpointslice => k8s.io/endpointslice v0.32.1
+	k8s.io/external-connector => k8s.io/external-connector v0.32.1
+	k8s.io/kms => k8s.io/kms v0.32.1
+	k8s.io/kube-aggregator => k8s.io/kube-aggregator v0.32.1
+	k8s.io/kube-controller-manager => k8s.io/kube-controller-manager v0.32.1
+	k8s.io/kube-proxy => k8s.io/kube-proxy v0.32.1
+	k8s.io/kube-scheduler => k8s.io/kube-scheduler v0.32.1
+	k8s.io/kubectl => k8s.io/kubectl v0.32.1
+	k8s.io/kubelet => k8s.io/kubelet v0.32.1
+	k8s.io/legacy-cloud-providers => k8s.io/legacy-cloud-providers v0.32.1
+	k8s.io/metrics => k8s.io/metrics v0.32.1
+	k8s.io/mount-utils => k8s.io/mount-utils v0.32.1
+	k8s.io/node-api => k8s.io/node-api v0.32.1
+	k8s.io/pod-security-admission => k8s.io/pod-security-admission v0.32.1
+	k8s.io/sample-apiserver => k8s.io/sample-apiserver v0.32.1
+	k8s.io/sample-cli-plugin => k8s.io/sample-cli-plugin v0.32.1
+	k8s.io/sample-controller => k8s.io/sample-controller v0.32.1
+)