- Sort Score
- Result 10 results
- Languages All
Results 71 - 80 of 1,432 for stopCh (0.35 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()")
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 22 05:08:41 UTC 2024 - 15.1K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/watch/watch.go
func (pw *ProxyWatcher) StopChan() <-chan struct{} { return pw.stopCh } // MockWatcher implements watch.Interface with mockable functions. type MockWatcher struct { StopFunc func() ResultChanFunc func() <-chan Event } var _ Interface = &MockWatcher{} // Stop calls StopFunc func (mw MockWatcher) Stop() { mw.StopFunc() } // ResultChan calls ResultChanFunc
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 20:06:22 UTC 2024 - 8.1K bytes - Viewed (1) -
pilot/pkg/serviceregistry/kube/controller/autoserviceexportcontroller.go
c.services.AddEventHandler(controllers.EventHandler[controllers.Object]{AddFunc: c.queue.AddObject}) return c } func (c *autoServiceExportController) Run(stopCh <-chan struct{}) { kube.WaitForCacheSync("auto service export", stopCh, c.services.HasSynced) c.queue.Run(stopCh) c.services.ShutdownHandlers() } func (c *autoServiceExportController) logPrefix() string { return "AutoServiceExport (cluster=" + c.ClusterID.String() + ") "
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Feb 28 16:41:38 UTC 2024 - 5.7K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/dynamiccertificates/tlsconfig.go
_ = c.RunOnce() // doesn't matter what workers say, only start one. go wait.Until(c.runWorker, time.Second, stopCh) // start timer that rechecks every minute, just in case. this also serves to prime the controller quickly. go wait.Until(func() { c.Enqueue() }, 1*time.Minute, stopCh) <-stopCh } func (c *DynamicServingCertificateController) runWorker() { for c.processNextWorkItem() { } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 10.3K bytes - Viewed (0) -
pkg/kubelet/cloudresource/cloud_request_manager_test.go
// Set the request delay so the manager timeouts and collects the node addresses later RequestDelay: 200 * time.Millisecond, } stopCh := make(chan struct{}) defer close(stopCh) manager := NewSyncManager(cloud, "defaultNode", syncPeriod).(*cloudResourceSyncManager) go manager.Run(stopCh) nodeAddresses, err := manager.NodeAddresses() if err != nil { t.Errorf("Unexpected err: %q\n", err) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 12 15:48:03 UTC 2023 - 4.2K bytes - Viewed (0) -
pkg/scheduler/internal/cache/debugger/debugger.go
func (d *CacheDebugger) ListenForSignal(ctx context.Context) { logger := klog.FromContext(ctx) stopCh := ctx.Done() ch := make(chan os.Signal, 1) signal.Notify(ch, compareSignal) go func() { for { select { case <-stopCh: return case <-ch: d.Comparer.Compare(logger) d.Dumper.DumpAll(logger) } } }()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 29 05:26:32 UTC 2023 - 1.9K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/storagebackend/factory/etcd3.go
} return l } func newETCD3HealthCheck(c storagebackend.Config, stopCh <-chan struct{}) (func() error, error) { timeout := storagebackend.DefaultHealthcheckTimeout if c.HealthcheckTimeout != time.Duration(0) { timeout = c.HealthcheckTimeout } return newETCD3Check(c, timeout, stopCh) } func newETCD3ReadyCheck(c storagebackend.Config, stopCh <-chan struct{}) (func() error, error) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 07:56:39 UTC 2024 - 15.1K bytes - Viewed (0) -
pkg/kubemark/controller.go
func (kubemarkController *KubemarkController) Run(stopCh chan struct{}) { nodeTemplate, err := kubemarkController.getNodeTemplate() if err != nil { klog.Fatalf("failed to get node template: %s", err) } kubemarkController.nodeTemplate = nodeTemplate go kubemarkController.runNodeCreation(stopCh) <-stopCh } // GetNodeNamesForNodeGroup returns list of the nodes in the node group.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jul 17 23:02:17 UTC 2020 - 14.1K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/deprecated_insecure_serving.go
// Serve starts an insecure http server with the given handler. It fails only if // the initial listen call fails. It does not block. func (s *DeprecatedInsecureServingInfo) Serve(handler http.Handler, shutdownTimeout time.Duration, stopCh <-chan struct{}) error { insecureServer := &http.Server{ Addr: s.Listener.Addr().String(), Handler: handler, MaxHeaderBytes: 1 << 20,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jul 27 15:58:45 UTC 2021 - 3.2K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/request/object_count_tracker.go
return 0, ObjectCountNotFoundErr } // RunUntil runs all the necessary maintenance. func (t *objectCountTracker) RunUntil(stopCh <-chan struct{}) { wait.PollUntil( pruneInterval, func() (bool, error) { // always prune at every pruneInterval return false, t.prune(pruneInterval) }, stopCh) klog.InfoS("StorageObjectCountTracker pruner is exiting") }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 16 09:12:00 UTC 2022 - 5K bytes - Viewed (0)