- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 1,061 for stopCh (0.15 sec)
-
staging/src/k8s.io/apiserver/pkg/admission/initializer/initializer_test.go
func TestWantsShutdownNotification(t *testing.T) { stopCh := make(chan struct{}) target := initializer.New(nil, nil, nil, &TestAuthorizer{}, nil, stopCh, nil) wantDrainedNotification := &WantDrainedNotification{} target.Initialize(wantDrainedNotification) if wantDrainedNotification.stopCh == nil { t.Errorf("expected stopCh to be initialized but found nil") } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 06 00:00:21 UTC 2024 - 8.2K bytes - Viewed (0) -
pkg/controlplane/controller/kubernetesservice/controller.go
defer close(localStopCh) select { case <-stopCh: // from Start case <-c.stopCh: // from Stop } }() go c.Run(localStopCh) } // Stop cleans up this API Servers endpoint reconciliation leases so another master can take over more quickly. func (c *Controller) Stop() { c.lock.Lock() defer c.lock.Unlock() select { case <-c.stopCh: return // only close once default:
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Aug 16 16:33:01 UTC 2023 - 9.3K bytes - Viewed (0) -
pkg/controller/replicaset/replica_set_test.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 69.2K bytes - Viewed (0) -
pkg/test/framework/components/echo/kube/workload_manager.go
out, err := m.readyWorkloads() m.mutex.Unlock() return out, err } func (m *workloadManager) Start() error { // Run the pod controller. go m.podController.Run(m.stopCh) // Wait for the cache to sync. if !m.podController.WaitForSync(m.stopCh) { return fmt.Errorf( "failed syncing cache for echo %s/%s: controller stopping", m.cfg.Namespace.Name(), m.cfg.Service) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Aug 14 02:12:37 UTC 2023 - 6.4K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/policy/generic/plugin.go
c.restMapper = mapper } func (c *Plugin[H]) SetDynamicClient(client dynamic.Interface) { c.dynamicClient = client } func (c *Plugin[H]) SetDrainedNotification(stopCh <-chan struct{}) { c.stopCh = stopCh } func (c *Plugin[H]) SetAuthorizer(authorizer authorizer.Authorizer) { c.authorizer = authorizer } func (c *Plugin[H]) SetMatcher(matcher *matching.Matcher) { c.matcher = matcher
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 05 19:11:10 UTC 2024 - 6.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_test.go
wg.Wait() c <- struct{}{} }() select { case <-c: return true case <-time.After(timeout): return false } } func TestSendPushesManyPushes(t *testing.T) { stopCh := make(chan struct{}) defer close(stopCh) semaphore := make(chan struct{}, 2) queue := NewPushQueue() defer queue.ShutDown() proxies := createProxies(5) pushes := make(map[string]int) pushesMu := &sync.Mutex{}
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 30 00:26:45 UTC 2024 - 9.2K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/reconcilers/peer_endpoint_lease.go
} }, c.endpointInterval, stopCh) } // Stop cleans up this apiserver's peer endpoint leases. func (c *PeerEndpointLeaseController) Stop() { c.lock.Lock() defer c.lock.Unlock() select { case <-c.stopCh: return // only close once default: close(c.stopCh) } finishedReconciling := make(chan struct{}) go func() {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Aug 24 09:23:05 UTC 2023 - 12.3K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/secure_serving.go
s.Cert.AddListener(dynamicCertificateController) } // generate a context from stopCh. This is to avoid modifying files which are relying on apiserver // TODO: See if we can pass ctx to the current method ctx, cancel := context.WithCancel(context.Background()) go func() { select { case <-stopCh: cancel() // stopCh closed, so cancel our context case <-ctx.Done(): } }()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Oct 12 20:54:07 UTC 2023 - 10.3K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/initializer/initializer.go
authz authorizer.Authorizer, featureGates featuregate.FeatureGate, stopCh <-chan struct{}, restMapper meta.RESTMapper, ) pluginInitializer { return pluginInitializer{ externalClient: extClientset, dynamicClient: dynamicClient, externalInformers: extInformers, authorizer: authz, featureGates: featureGates, stopCh: stopCh, restMapper: restMapper, } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 06 00:00:21 UTC 2024 - 3K bytes - Viewed (0)