- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 21 for WaitForNamedCacheSync (0.65 sec)
-
cmd/kube-controller-manager/names/controller_names.go
// 2.3. [TODO] registering ControllerManagerMetrics with ControllerStarted and ControllerStopped // 2.4. [TODO] calling WaitForNamedCacheSync // 3. defining controller options for "--help" command or generated documentation
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 08 19:25:10 UTC 2024 - 5.7K 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) -
plugin/pkg/auth/authorizer/node/graph_populator.go
AddFunc: g.addResourceSlice, UpdateFunc: nil, // Not needed, NodeName is immutable. DeleteFunc: g.deleteResourceSlice, }) synced = append(synced, sliceHandler.HasSynced) } go cache.WaitForNamedCacheSync("node_authorizer", wait.NeverStop, synced...) } func (g *graphPopulator) addPod(obj interface{}) { g.updatePod(nil, obj) } func (g *graphPopulator) updatePod(oldObj, obj interface{}) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 21:22:55 UTC 2024 - 6.5K 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)