- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 505 for stopCh (0.24 sec)
-
pkg/controlplane/controller/legacytokentracking/controller.go
// Run starts the controller sync loop. func (c *Controller) Run(stopCh <-chan struct{}) { defer utilruntime.HandleCrash() 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 }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 6K bytes - Viewed (0) -
pkg/controlplane/controller/systemnamespaces/system_namespaces_controller.go
interval: interval, } } // Run starts one worker. func (c *Controller) Run(stopCh <-chan struct{}) { defer utilruntime.HandleCrash() defer klog.Infof("Shutting down system namespaces controller") klog.Infof("Starting system namespaces controller") if !cache.WaitForCacheSync(stopCh, c.namespaceSynced) { utilruntime.HandleError(fmt.Errorf("timed out waiting for caches to sync")) return }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Apr 27 12:19:56 UTC 2024 - 2.9K bytes - Viewed (0) -
pilot/pkg/xds/discovery.go
return s.serverReady.Load() } func (s *DiscoveryServer) Start(stopCh <-chan struct{}) { go s.WorkloadEntryController.Run(stopCh) go s.handleUpdates(stopCh) go s.periodicRefreshMetrics(stopCh) go s.sendPushes(stopCh) go s.Cache.Run(stopCh) } // Push metrics are updated periodically (10s default) func (s *DiscoveryServer) periodicRefreshMetrics(stopCh <-chan struct{}) { ticker := time.NewTicker(periodicRefreshMetrics)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 15 20:21:09 UTC 2024 - 19K bytes - Viewed (0) -
pkg/revisions/tag_watcher.go
} return []string{rev} }, controllers.ObjectHandler(p.queue.AddObject)) return p } func (p *tagWatcher) Run(stopCh <-chan struct{}) { if !kube.WaitForCacheSync("tag watcher", stopCh, p.webhooks.HasSynced) { return } // Notify handlers of initial state p.notifyHandlers() p.queue.Run(stopCh) } // AddHandler registers a new handler for updates to tag changes. func (p *tagWatcher) AddHandler(handler TagHandler) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 00:12:28 UTC 2024 - 3.3K bytes - Viewed (0) -
pkg/controlplane/apiserver/server.go
return err }) } } s.GenericAPIServer.AddPostStartHookOrDie("start-cluster-authentication-info-controller", func(hookContext genericapiserver.PostStartHookContext) error { controller := clusterauthenticationtrust.NewClusterAuthenticationTrustController(s.ClusterAuthenticationInfo, client)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 29 19:24:41 UTC 2024 - 11K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/healthz/healthz.go
func (s *shutdown) Check(req *http.Request) error { select { case <-s.stopCh: return fmt.Errorf("process is shutting down") default: } return nil } func (i *informerSync) Check(_ *http.Request) error { stopCh := make(chan struct{}) // Close stopCh to force checking if informers are synced now. close(stopCh) informersByStarted := make(map[bool][]string)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 27 19:11:24 UTC 2024 - 10.5K bytes - Viewed (0) -
pkg/kubelet/volumemanager/reconciler/reconciler.go
*/ package reconciler import ( "k8s.io/apimachinery/pkg/util/wait" "k8s.io/klog/v2" ) func (rc *reconciler) Run(stopCh <-chan struct{}) { rc.reconstructVolumes() klog.InfoS("Reconciler: start to sync state") wait.Until(rc.reconcile, rc.loopSleepDuration, stopCh) } func (rc *reconciler) reconcile() { readyToUnmount := rc.readyToUnmount() if readyToUnmount {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 21 10:23:12 UTC 2024 - 2.1K bytes - Viewed (0) -
pkg/kube/multicluster/secretcontroller_test.go
return t.component.clusters["config"] } func (t *testController) Run(stop chan struct{}) { assert.NoError(t.t, t.controller.Run(stop)) t.client.RunAndWait(stop) } func TestListRemoteClusters(t *testing.T) { stop := make(chan struct{}) c := buildTestController(t, false) c.AddSecret("s0", "c0") c.AddSecret("s1", "c1") c.Run(stop) // before sync
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 15:07:03 UTC 2024 - 17.6K bytes - Viewed (0) -
pkg/controller/garbagecollector/graph_builder.go
ignoredResources map[schema.GroupResource]struct{} } // monitor runs a Controller with a local stop channel. type monitor struct { controller cache.Controller store cache.Store // stopCh stops Controller. If stopCh is nil, the monitor is considered to be // not yet started. stopCh chan struct{} } // Run is intended to be called in a goroutine. Multiple calls of this is an // error.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 36.9K bytes - Viewed (0) -
pkg/controlplane/controller/defaultservicecidr/default_servicecidr_controller.go
serviceCIDRsSynced cache.InformerSynced interval time.Duration } // Start will not return until the default ServiceCIDR exists or stopCh is closed. func (c *Controller) Start(ctx context.Context) { defer utilruntime.HandleCrash() stopCh := ctx.Done() c.eventBroadcaster = record.NewBroadcaster(record.WithContext(ctx))
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 29 18:59:21 UTC 2024 - 7.5K bytes - Viewed (0)