- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 364 for stopCh (0.35 sec)
-
staging/src/k8s.io/apiserver/pkg/admission/plugin/webhook/mutating/plugin_test.go
wh.SetAuthenticationInfoResolverWrapper(webhooktesting.Wrapper(webhooktesting.NewAuthenticationInfoResolver(new(int32)))) wh.SetServiceResolver(webhooktesting.NewServiceResolver(*serverURL)) wh.SetExternalKubeClientSet(client) wh.SetExternalKubeInformerFactory(informer) informer.Start(stopCh) informer.WaitForCacheSync(stopCh)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 01 06:06:52 UTC 2024 - 11K bytes - Viewed (0) -
pkg/proxy/config/config_test.go
stopCh := make(chan struct{}) defer close(stopCh) sharedInformers := informers.NewSharedInformerFactory(client, time.Minute) config := NewServiceConfig(ctx, sharedInformers.Core().V1().Services(), time.Minute) handler := NewServiceHandlerMock() config.RegisterEventHandler(handler) go sharedInformers.Start(stopCh) go config.Run(stopCh) service := &v1.Service{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 22 05:08:41 UTC 2024 - 14.3K bytes - Viewed (0) -
pkg/kubelet/volumemanager/volume_manager_test.go
manager := newTestVolumeManager(t, tmpDir, podManager, kubeClient, node) stopCh := runVolumeManager(manager) defer close(stopCh) podManager.SetPods([]*v1.Pod{pod}) // Fake node status update go simulateVolumeInUseUpdate( v1.UniqueVolumeName(node.Status.VolumesAttached[0].Name), stopCh, manager) err = manager.WaitForAttachAndMount(context.Background(), pod)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 14.1K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/webhook/validating/plugin_test.go
wh.SetAuthenticationInfoResolverWrapper(webhooktesting.Wrapper(webhooktesting.NewAuthenticationInfoResolver(new(int32)))) wh.SetServiceResolver(webhooktesting.NewServiceResolver(*serverURL)) wh.SetExternalKubeClientSet(client) wh.SetExternalKubeInformerFactory(informer) informer.Start(stopCh) informer.WaitForCacheSync(stopCh)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 01 06:06:52 UTC 2024 - 11.9K bytes - Viewed (0) -
pkg/controller/resourcequota/resource_quota_monitor.go
} // monitor runs a Controller with a local stop channel. type monitor struct { controller cache.Controller // 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. func (m *monitor) Run() { m.controller.Run(m.stopCh) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 11.6K bytes - Viewed (0) -
pkg/kubelet/util/manager/watch_based_manager.go
// lock is to ensure the access and modify of lastAccessTime, stopped, and immutable are thread safety, // and protecting from closing stopCh multiple times. lock sync.Mutex lastAccessTime time.Time stopped bool immutable bool stopCh chan struct{} } func (i *objectCacheItem) stop() bool { i.lock.Lock() defer i.lock.Unlock() return i.stopThreadUnsafe() }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 11.6K 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/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/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)