Search Options

Results per page
Sort
Preferred Languages
Advance

Results 71 - 80 of 1,432 for stopCh (0.15 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. pkg/kubelet/pluginmanager/reconciler/reconciler.go

    	handlers            map[string]cache.PluginHandler
    	sync.RWMutex
    }
    
    var _ Reconciler = &reconciler{}
    
    func (rc *reconciler) Run(stopCh <-chan struct{}) {
    	wait.Until(func() {
    		rc.reconcile()
    	},
    		rc.loopSleepDuration,
    		stopCh)
    }
    
    func (rc *reconciler) AddHandler(pluginType string, pluginHandler cache.PluginHandler) {
    	rc.Lock()
    	defer rc.Unlock()
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sun Dec 18 04:27:38 UTC 2022
    - 6.2K bytes
    - Viewed (0)
  10. 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)
Back to top