- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 51 for WaitForNamedCacheSync (1.28 sec)
-
pkg/controller/nodeipam/ipam/range_allocator.go
defer r.broadcaster.Shutdown() defer r.queue.ShutDown() logger.Info("Starting range CIDR allocator") defer logger.Info("Shutting down range CIDR allocator") if !cache.WaitForNamedCacheSync("cidrallocator", ctx.Done(), r.nodesSynced) { return } for i := 0; i < cidrUpdateWorkers; i++ { go wait.UntilWithContext(ctx, r.runWorker, time.Second) } <-ctx.Done() }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 10:06:15 UTC 2024 - 16.2K bytes - Viewed (0) -
pkg/controller/tainteviction/taint_eviction.go
klog.FlushAndExit(klog.ExitFlushTimeout, 1) } defer tc.broadcaster.Shutdown() defer tc.nodeUpdateQueue.ShutDown() defer tc.podUpdateQueue.ShutDown() // wait for the cache to be synced if !cache.WaitForNamedCacheSync(tc.name, ctx.Done(), tc.podListerSynced, tc.nodeListerSynced) { return } for i := 0; i < UpdateWorkerSize; i++ {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 19.9K bytes - Viewed (0) -
pkg/controller/serviceaccount/tokens_controller.go
func (e *TokensController) Run(ctx context.Context, workers int) { // Shut down queues defer utilruntime.HandleCrash() defer e.syncServiceAccountQueue.ShutDown() defer e.syncSecretQueue.ShutDown() if !cache.WaitForNamedCacheSync("tokens", ctx.Done(), e.serviceAccountSynced, e.secretSynced) { return } logger := klog.FromContext(ctx) logger.V(5).Info("Starting workers") for i := 0; i < workers; i++ {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 20.5K bytes - Viewed (0) -
pkg/controller/statefulset/stateful_set.go
defer ssc.queue.ShutDown() logger := klog.FromContext(ctx) logger.Info("Starting stateful set controller") defer logger.Info("Shutting down statefulset controller") if !cache.WaitForNamedCacheSync("stateful set", ctx.Done(), ssc.podListerSynced, ssc.setListerSynced, ssc.pvcListerSynced, ssc.revListerSynced) { return } for i := 0; i < workers; i++ {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 05 19:06:41 UTC 2024 - 18.5K bytes - Viewed (0) -
pkg/controller/endpointslicemirroring/endpointslicemirroring_controller.go
defer c.queue.ShutDown() logger := klog.FromContext(ctx) logger.Info("Starting EndpointSliceMirroring controller") defer logger.Info("Shutting down EndpointSliceMirroring controller") if !cache.WaitForNamedCacheSync("endpoint_slice_mirroring", ctx.Done(), c.endpointsSynced, c.endpointSlicesSynced, c.servicesSynced) { return } logger.V(2).Info("Starting worker threads", "total", workers) for i := 0; i < workers; i++ {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 06 23:18:31 UTC 2024 - 20.1K bytes - Viewed (0) -
pkg/controller/endpointslice/endpointslice_controller.go
defer c.topologyQueue.ShutDown() logger := klog.FromContext(ctx) logger.Info("Starting endpoint slice controller") defer logger.Info("Shutting down endpoint slice controller") if !cache.WaitForNamedCacheSync("endpoint_slice", ctx.Done(), c.podsSynced, c.servicesSynced, c.endpointSlicesSynced, c.nodesSynced) { return } logger.V(2).Info("Starting service queue worker threads", "total", workers)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 08:33:32 UTC 2024 - 23.6K bytes - Viewed (0) -
pkg/controller/deployment/deployment_controller.go
logger := klog.FromContext(ctx) logger.Info("Starting controller", "controller", "deployment") defer logger.Info("Shutting down controller", "controller", "deployment") if !cache.WaitForNamedCacheSync("deployment", ctx.Done(), dc.dListerSynced, dc.rsListerSynced, dc.podListerSynced) { return } for i := 0; i < workers; i++ { go wait.UntilWithContext(ctx, dc.worker, time.Second) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 24.2K bytes - Viewed (0) -
pkg/controller/volume/persistentvolume/pv_controller_base.go
defer ctrl.eventBroadcaster.Shutdown() logger := klog.FromContext(ctx) logger.Info("Starting persistent volume controller") defer logger.Info("Shutting down persistent volume controller") if !cache.WaitForNamedCacheSync("persistent volume", ctx.Done(), ctrl.volumeListerSynced, ctrl.claimListerSynced, ctrl.classListerSynced, ctrl.podListerSynced, ctrl.NodeListerSynced) { return }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 10 08:42:31 UTC 2024 - 29.5K bytes - Viewed (0) -
pkg/registry/core/service/ipallocator/controller/repairip.go
r.broadcaster.StartRecordingToSink(stopCh) defer r.broadcaster.Shutdown() klog.Info("Starting ipallocator-repair-controller") defer klog.Info("Shutting down ipallocator-repair-controller") if !cache.WaitForNamedCacheSync("ipallocator-repair-controller", stopCh, r.ipAddressSynced, r.servicesSynced, r.serviceCIDRSynced) { return } // First sync goes through all the Services and IPAddresses in the cache,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 24.7K bytes - Viewed (0) -
pkg/controller/endpoint/endpoints_controller.go
defer e.queue.ShutDown() logger := klog.FromContext(ctx) logger.Info("Starting endpoint controller") defer logger.Info("Shutting down endpoint controller") if !cache.WaitForNamedCacheSync("endpoint", ctx.Done(), e.podsSynced, e.servicesSynced, e.endpointsSynced) { return } for i := 0; i < workers; i++ { go wait.UntilWithContext(ctx, e.worker, e.workerLoopPeriod) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 26.3K bytes - Viewed (0)