- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 1,256 for stopCh (0.1 sec)
-
pkg/kubelet/certificate/transport.go
// certificate. // // stopCh should be used to indicate when the transport is unused and doesn't need // to continue checking the manager. func UpdateTransport(stopCh <-chan struct{}, clientConfig *restclient.Config, clientCertificateManager certificate.Manager, exitAfter time.Duration) (func(), error) { return updateTransport(stopCh, 10*time.Second, clientConfig, clientCertificateManager, exitAfter) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Dec 08 13:57:45 UTC 2022 - 6.5K bytes - Viewed (0) -
pkg/kubelet/runtimeclass/testing/fake_manager.go
// Returns a function to stop the manager, which should be called with a defer: // // defer StartManagerSync(t, m)() func StartManagerSync(m *runtimeclass.Manager) func() { stopCh := make(chan struct{}) m.Start(stopCh) m.WaitForCacheSync(stopCh) return func() { close(stopCh) } } // NewRuntimeClass is a helper to generate a RuntimeClass resource with
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jul 26 17:14:05 UTC 2022 - 2.1K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/cacher/watch_progress.go
cond *sync.Cond waiting int stopped bool } func (pr *conditionalProgressRequester) Run(stopCh <-chan struct{}) { ctx := wait.ContextForChannel(stopCh) if pr.contextMetadata != nil { ctx = metadata.NewOutgoingContext(ctx, pr.contextMetadata) } go func() { defer utilruntime.HandleCrash() <-stopCh pr.mux.Lock() defer pr.mux.Unlock() pr.stopped = true pr.cond.Signal() }()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 24 09:56:38 UTC 2024 - 3K bytes - Viewed (0) -
pkg/test/loadbalancersim/timer/queue.go
type Queue struct { heap timerHeap mutex sync.Mutex stopCh chan struct{} resetTimerCh chan struct{} stopping bool timer *time.Timer currentDeadline time.Time } func NewQueue() *Queue { q := &Queue{ heap: make(timerHeap, 0), timer: time.NewTimer(1 * time.Minute), stopCh: make(chan struct{}), resetTimerCh: make(chan struct{}), }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jul 20 19:13:32 UTC 2023 - 3.6K bytes - Viewed (0) -
pilot/pkg/config/kube/ingress/controller_test.go
t.Fatalf("timed out waiting for config") } return config.Config{} } controller.RegisterEventHandler(gvk.VirtualService, configHandler) stopCh := make(chan struct{}) go controller.Run(stopCh) defer close(stopCh) client.RunAndWait(stopCh) ingress.Create(&ingress1) vs := wait() if vs.Name != ingress1.Name+"-"+"virtualservice" || vs.Namespace != ingress1.Namespace {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jul 20 18:34:32 UTC 2023 - 10.1K bytes - Viewed (0) -
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)