- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 1,061 for stopCh (0.12 sec)
-
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) -
staging/src/k8s.io/apiserver/pkg/server/hooks.go
LoopbackClientConfig *restclient.Config // StopCh is the channel that will be closed when the server stops. // // Deprecated: use the PostStartHookContext itself instead, it contains a context that // gets cancelled when the server stops. StopCh keeps getting provided for existing code. StopCh <-chan struct{} // Context gets cancelled when the server stops. context.Context }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 29 18:59:21 UTC 2024 - 8K bytes - Viewed (0) -
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) -
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/util/concurrent/debouncer.go
// limitations under the License. package concurrent import ( "time" "istio.io/istio/pkg/util/sets" ) type Debouncer[T comparable] struct{} func (d *Debouncer[T]) Run(ch chan T, stopCh <-chan struct{}, debounceMinInterval, debounceMaxInterval time.Duration, pushFn func(sets.Set[T])) { var timeChan <-chan time.Time var startDebounce time.Time var lastConfigUpdateTime time.Time pushCounter := 0
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Apr 01 13:44:06 UTC 2024 - 2.4K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/apiserver/customresource_discovery_controller.go
}) } func (c *DiscoveryController) Run(stopCh <-chan struct{}, synchedCh chan<- struct{}) { defer utilruntime.HandleCrash() defer c.queue.ShutDown() defer klog.Info("Shutting down DiscoveryController") klog.Info("Starting DiscoveryController") if !cache.WaitForCacheSync(stopCh, c.crdsSynced) { utilruntime.HandleError(fmt.Errorf("timed out waiting for caches to sync"))
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Apr 21 11:40:03 UTC 2024 - 12.8K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/controller/apiapproval/apiapproval_controller.go
func (c *KubernetesAPIApprovalPolicyConformantConditionController) Run(workers int, stopCh <-chan struct{}) { defer utilruntime.HandleCrash() defer c.queue.ShutDown() klog.Infof("Starting KubernetesAPIApprovalPolicyConformantConditionController") defer klog.Infof("Shutting down KubernetesAPIApprovalPolicyConformantConditionController") if !cache.WaitForCacheSync(stopCh, c.crdSynced) { return } 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 - 9.2K bytes - Viewed (0)