...
1
16
17 package fuzzer
18
19 import (
20 "fmt"
21
22 "github.com/google/gofuzz"
23
24 runtimeserializer "k8s.io/apimachinery/pkg/runtime/serializer"
25 kubectrlmgrconfig "k8s.io/kubernetes/pkg/controller/apis/config"
26 )
27
28
29 func Funcs(codecs runtimeserializer.CodecFactory) []interface{} {
30 return []interface{}{
31 func(obj *kubectrlmgrconfig.KubeControllerManagerConfiguration, c fuzz.Continue) {
32 c.FuzzNoCustom(obj)
33 obj.Generic.Address = fmt.Sprintf("%d.%d.%d.%d", c.Intn(256), c.Intn(256), c.Intn(256), c.Intn(256))
34 obj.Generic.ClientConnection.ContentType = fmt.Sprintf("%s/%s.%s.%s", c.RandString(), c.RandString(), c.RandString(), c.RandString())
35 if obj.Generic.LeaderElection.ResourceLock == "" {
36 obj.Generic.LeaderElection.ResourceLock = "endpoints"
37 }
38 obj.Generic.Controllers = []string{fmt.Sprintf("%s", c.RandString())}
39 if obj.KubeCloudShared.ClusterName == "" {
40 obj.KubeCloudShared.ClusterName = "kubernetes"
41 }
42 obj.CSRSigningController.ClusterSigningCertFile = fmt.Sprintf("/%s", c.RandString())
43 obj.CSRSigningController.ClusterSigningKeyFile = fmt.Sprintf("/%s", c.RandString())
44 obj.PersistentVolumeBinderController.VolumeConfiguration.FlexVolumePluginDir = fmt.Sprintf("/%s", c.RandString())
45 obj.TTLAfterFinishedController.ConcurrentTTLSyncs = c.Int31()
46 },
47 }
48 }
49
View as plain text