- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 51 for WaitForNamedCacheSync (0.4 sec)
-
pkg/proxy/config/config.go
} // Run waits for cache synced and invokes handlers after syncing. func (c *EndpointSliceConfig) Run(stopCh <-chan struct{}) { c.logger.Info("Starting endpoint slice config controller") if !cache.WaitForNamedCacheSync("endpoint slice config", stopCh, c.listerSynced) { return } for _, h := range c.eventHandlers { c.logger.V(3).Info("Calling handler.OnEndpointSlicesSynced()") h.OnEndpointSlicesSynced() }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 22 05:08:41 UTC 2024 - 15.1K bytes - Viewed (0) -
pkg/controller/validatingadmissionpolicystatus/controller.go
typeChecker *validatingadmissionpolicy.TypeChecker } func (c *Controller) Run(ctx context.Context, workers int) { defer utilruntime.HandleCrash() if !cache.WaitForNamedCacheSync(ControllerName, ctx.Done(), c.policySynced) { return } defer c.policyQueue.ShutDown() for i := 0; i < workers; i++ { go wait.UntilWithContext(ctx, c.runWorker, time.Second) } <-ctx.Done()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 5.3K bytes - Viewed (0) -
pkg/controller/nodeipam/node_ipam_controller.go
defer nc.eventBroadcaster.Shutdown() klog.FromContext(ctx).Info("Starting ipam controller") defer klog.FromContext(ctx).Info("Shutting down ipam controller") if !cache.WaitForNamedCacheSync("node", ctx.Done(), nc.nodeInformerSynced) { return } if nc.allocatorType == ipam.IPAMFromClusterAllocatorType || nc.allocatorType == ipam.IPAMFromCloudAllocatorType { go nc.legacyIPAM.Run(ctx)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jun 06 16:18:38 UTC 2024 - 5.4K bytes - Viewed (0) -
pkg/controlplane/controller/legacytokentracking/controller.go
defer c.queue.ShutDown() klog.Info("Starting legacy_token_tracking_controller") defer klog.Infof("Shutting down legacy_token_tracking_controller") go c.configMapInformer.Run(stopCh) if !cache.WaitForNamedCacheSync("configmaps", stopCh, c.configMapSynced) { return } go wait.Until(c.runWorker, time.Second, stopCh) c.queue.Add(queueKey) <-stopCh klog.Info("Ending legacy_token_tracking_controller")
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 6K bytes - Viewed (0) -
pkg/controller/certificates/certificate_controller.go
logger := klog.FromContext(ctx) logger.Info("Starting certificate controller", "name", cc.name) defer logger.Info("Shutting down certificate controller", "name", cc.name) if !cache.WaitForNamedCacheSync(fmt.Sprintf("certificate-%s", cc.name), ctx.Done(), cc.csrsSynced) { return } for i := 0; i < workers; i++ { go wait.UntilWithContext(ctx, cc.worker, time.Second) } <-ctx.Done() }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 6.4K bytes - Viewed (0) -
pkg/controller/certificates/rootcacertpublisher/publisher.go
defer c.queue.ShutDown() logger := klog.FromContext(ctx) logger.Info("Starting root CA cert publisher controller") defer logger.Info("Shutting down root CA cert publisher controller") if !cache.WaitForNamedCacheSync("crt configmap", ctx.Done(), c.cmListerSynced) { return } for i := 0; i < workers; i++ { go wait.UntilWithContext(ctx, c.runWorker, time.Second) } <-ctx.Done() }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 6.8K bytes - Viewed (0) -
pkg/controller/volume/pvprotection/pv_protection_controller.go
defer c.queue.ShutDown() logger := klog.FromContext(ctx) logger.Info("Starting PV protection controller") defer logger.Info("Shutting down PV protection controller") if !cache.WaitForNamedCacheSync("PV protection", ctx.Done(), c.pvListerSynced) { return } for i := 0; i < workers; i++ { go wait.UntilWithContext(ctx, c.runWorker, time.Second) } <-ctx.Done() }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 6.4K bytes - Viewed (0) -
pkg/controller/clusterroleaggregation/clusterroleaggregation_controller.go
defer c.queue.ShutDown() logger := klog.FromContext(ctx) logger.Info("Starting ClusterRoleAggregator controller") defer logger.Info("Shutting down ClusterRoleAggregator controller") if !cache.WaitForNamedCacheSync("ClusterRoleAggregator", ctx.Done(), c.clusterRolesSynced) { return } for i := 0; i < workers; i++ { go wait.UntilWithContext(ctx, c.runWorker, time.Second) } <-ctx.Done() }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 8K bytes - Viewed (0) -
pkg/controller/bootstrap/tokencleaner.go
defer tc.queue.ShutDown() logger := klog.FromContext(ctx) logger.Info("Starting token cleaner controller") defer logger.Info("Shutting down token cleaner controller") if !cache.WaitForNamedCacheSync("token_cleaner", ctx.Done(), tc.secretSynced) { return } go wait.UntilWithContext(ctx, tc.worker, 10*time.Second) <-ctx.Done() }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 6.3K bytes - Viewed (0) -
pkg/controller/serviceaccount/serviceaccounts_controller.go
defer c.queue.ShutDown() klog.FromContext(ctx).Info("Starting service account controller") defer klog.FromContext(ctx).Info("Shutting down service account controller") if !cache.WaitForNamedCacheSync("service account", ctx.Done(), c.saListerSynced, c.nsListerSynced) { return } for i := 0; i < workers; i++ { go wait.UntilWithContext(ctx, c.runWorker, time.Second) } <-ctx.Done() }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 7.5K bytes - Viewed (0)