- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 1,038 for stopCh (0.32 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/api_test.go
stopCh := make(chan struct{}) defer close(stopCh) handler := NewServiceHandlerMock() sharedInformers := informers.NewSharedInformerFactory(client, time.Minute) serviceConfig := NewServiceConfig(ctx, sharedInformers.Core().V1().Services(), time.Minute) serviceConfig.RegisterEventHandler(handler) go sharedInformers.Start(stopCh) go serviceConfig.Run(stopCh)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 22 05:08:41 UTC 2024 - 8.2K 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) -
staging/src/k8s.io/apiextensions-apiserver/pkg/apiserver/apiserver.go
go nonStructuralSchemaController.Run(5, context.StopCh) go apiApprovalController.Run(5, context.StopCh) go finalizingController.Run(5, context.StopCh) discoverySyncedCh := make(chan struct{}) go discoveryController.Run(context.StopCh, discoverySyncedCh) select { case <-context.StopCh: case <-discoverySyncedCh: } return nil })
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Oct 19 14:31:43 UTC 2023 - 11.5K bytes - Viewed (0) -
pkg/kube/portforwarder.go
} func (f *forwarder) Close() { close(f.stopCh) // Closing the stop channel should close anything // opened by f.forwarder.ForwardPorts() } func (f *forwarder) ErrChan() <-chan error { return f.errCh } func (f *forwarder) WaitForStop() { <-f.stopCh }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Aug 14 02:12:37 UTC 2023 - 5.5K 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) -
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) -
plugin/pkg/admission/resourcequota/admission_test.go
return createHandlerWithConfig(kubeClient, informerFactory, nil, stopCh) } func createHandlerWithConfig(kubeClient kubernetes.Interface, informerFactory informers.SharedInformerFactory, config *resourcequotaapi.Configuration, stopCh chan struct{}) (*resourcequota.QuotaAdmission, error) { if config == nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 29 21:28:42 UTC 2024 - 84.1K bytes - Viewed (0)