mirrors/kyverno
mirrors/kyverno
1
0
Fork 0
mirror of https://github.com/kyverno/kyverno.git synced 2025-03-15 04:07:46 +00:00
Code Activity

remove the container flag genWorker from the admission controller (#7132)

Browse source 
Signed-off-by: ShutingZhao <shuting@nirmata.com>
This commit is contained in:
shuting 2023-05-09 00:10:53 +08:00 • committed by GitHub
parent 78a02a6102
commit 251e2c8239
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
1 changed files with 0 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
cmd/kyverno/main.go
View file

@ -69,7 +69,6 @@ func sanityChecks(apiserverClient apiserver.Interface) error {
func createNonLeaderControllers( func createNonLeaderControllers(
eng engineapi.Engine, eng engineapi.Engine,
genWorkers int,
kubeInformer kubeinformers.SharedInformerFactory, kubeInformer kubeinformers.SharedInformerFactory,
kyvernoInformer kyvernoinformer.SharedInformerFactory, kyvernoInformer kyvernoinformer.SharedInformerFactory,
kubeClient kubernetes.Interface, kubeClient kubernetes.Interface,
@ -181,7 +180,6 @@ func main() {
// will be removed in future and the configuration will be set only via configmaps // will be removed in future and the configuration will be set only via configmaps
serverIP string serverIP string
webhookTimeout int webhookTimeout int
genWorkers int
maxQueuedEvents int maxQueuedEvents int
autoUpdateWebhooks bool autoUpdateWebhooks bool
webhookRegistrationTimeout time.Duration webhookRegistrationTimeout time.Duration
@ -193,7 +191,6 @@ func main() {
flagset := flag.NewFlagSet("kyverno", flag.ExitOnError) flagset := flag.NewFlagSet("kyverno", flag.ExitOnError)
flagset.BoolVar(&dumpPayload, "dumpPayload", false, "Set this flag to activate/deactivate debug mode.") flagset.BoolVar(&dumpPayload, "dumpPayload", false, "Set this flag to activate/deactivate debug mode.")
flagset.IntVar(&webhookTimeout, "webhookTimeout", webhookcontroller.DefaultWebhookTimeout, "Timeout for webhook configurations.") flagset.IntVar(&webhookTimeout, "webhookTimeout", webhookcontroller.DefaultWebhookTimeout, "Timeout for webhook configurations.")
flagset.IntVar(&genWorkers, "genWorkers", 10, "Workers for generate controller.")
flagset.IntVar(&maxQueuedEvents, "maxQueuedEvents", 1000, "Maximum events to be queued.") flagset.IntVar(&maxQueuedEvents, "maxQueuedEvents", 1000, "Maximum events to be queued.")
flagset.StringVar(&serverIP, "serverIP", "", "IP address where Kyverno controller runs. Only required if out-of-cluster.") flagset.StringVar(&serverIP, "serverIP", "", "IP address where Kyverno controller runs. Only required if out-of-cluster.")
flagset.BoolVar(&autoUpdateWebhooks, "autoUpdateWebhooks", true, "Set this flag to 'false' to disable auto-configuration of the webhook.") flagset.BoolVar(&autoUpdateWebhooks, "autoUpdateWebhooks", true, "Set this flag to 'false' to disable auto-configuration of the webhook.")
@ -303,7 +300,6 @@ func main() {
// create non leader controllers // create non leader controllers
nonLeaderControllers, nonLeaderBootstrap := createNonLeaderControllers( nonLeaderControllers, nonLeaderBootstrap := createNonLeaderControllers(
engine, engine,
genWorkers,
kubeInformer, kubeInformer,
kyvernoInformer, kyvernoInformer,
setup.KubeClient, setup.KubeClient,