Search Options

Results per page
Sort
Preferred Languages
Advance

Results 51 - 60 of 1,061 for stopCh (0.39 sec)

  1. pkg/controller/tainteviction/taint_eviction.go

    	// into channels.
    	go func(stopCh <-chan struct{}) {
    		for {
    			nodeUpdate, shutdown := tc.nodeUpdateQueue.Get()
    			if shutdown {
    				break
    			}
    			hash := hash(nodeUpdate.nodeName, UpdateWorkerSize)
    			select {
    			case <-stopCh:
    				tc.nodeUpdateQueue.Done(nodeUpdate)
    				return
    			case tc.nodeUpdateChannels[hash] <- nodeUpdate:
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 19.9K bytes
    - Viewed (0)
  2. pkg/kube/multicluster/secretcontroller.go

    		if features.LocalClusterSecretWatcher && features.ExternalIstiod {
    			c.secrets.Start(stopCh)
    		}
    		if !kube.WaitForCacheSync("multicluster remote secrets", stopCh, c.secrets.HasSynced) {
    			return
    		}
    		log.Infof("multicluster remote secrets controller cache synced in %v", time.Since(t0))
    		c.queue.Run(stopCh)
    		c.handleDelete(c.configClusterID)
    	}()
    	return nil
    }
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Mar 06 02:13:10 UTC 2024
    - 12.7K bytes
    - Viewed (0)
  3. pkg/controller/deployment/deployment_controller_test.go

    	c, informers, err := f.newController(ctx)
    	if err != nil {
    		f.t.Fatalf("error creating Deployment controller: %v", err)
    	}
    	if startInformers {
    		stopCh := make(chan struct{})
    		defer close(stopCh)
    		informers.Start(stopCh)
    	}
    
    	err = c.syncDeployment(ctx, deploymentName)
    	if !expectError && err != nil {
    		f.t.Errorf("error syncing deployment: %v", err)
    	} else if expectError && err == nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 32.5K bytes
    - Viewed (0)
  4. cluster/images/etcd-version-monitor/etcd-version-monitor.go

    	// Register the metrics we defined above with prometheus.
    	customMetricRegistry.MustRegister(etcdVersion)
    
    	// Spawn threads for periodically scraping etcd version metrics.
    	stopCh := make(chan struct{})
    	defer close(stopCh)
    	go getVersionPeriodically(stopCh)
    
    	// Serve our metrics on listenAddress/metricsPath.
    	klog.Infof("Listening on: %v", listenAddress)
    	http.Handle(metricsPath, metrics.HandlerFor(gatherer, metrics.HandlerOpts{}))
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Dec 16 06:50:02 UTC 2023
    - 11.5K bytes
    - Viewed (0)
  5. staging/src/k8s.io/apiextensions-apiserver/pkg/controller/nonstructuralschema/nonstructuralschema_controller.go

    }
    
    // Run starts the controller.
    func (c *ConditionController) Run(workers int, stopCh <-chan struct{}) {
    	defer utilruntime.HandleCrash()
    	defer c.queue.ShutDown()
    
    	klog.Infof("Starting NonStructuralSchemaConditionController")
    	defer klog.Infof("Shutting down NonStructuralSchemaConditionController")
    
    	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
    - 8.3K bytes
    - Viewed (0)
  6. staging/src/k8s.io/apiextensions-apiserver/pkg/controller/openapiv3/controller.go

    func (c *Controller) Run(openAPIV3Service *handler3.OpenAPIService, stopCh <-chan struct{}) {
    	defer utilruntime.HandleCrash()
    	defer c.queue.ShutDown()
    	defer klog.Infof("Shutting down OpenAPI V3 controller")
    
    	klog.Infof("Starting OpenAPI V3 controller")
    
    	c.openAPIV3Service = openAPIV3Service
    
    	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: Sat May 04 18:33:12 UTC 2024
    - 7.9K bytes
    - Viewed (0)
  7. staging/src/k8s.io/apiserver/pkg/server/filters/priority-and-fairness_test.go

    			serverConcurrency, plConcurrencyShares, plConcurrency = 1, 1, 1
    		)
    
    		apfConfiguration := newConfiguration(fsName, plName, userName, plConcurrencyShares, 0)
    		stopCh := make(chan struct{})
    		controller, controllerCompletedCh := startAPFController(t, stopCh, apfConfiguration, serverConcurrency, plName, plConcurrency)
    
    		headerMatcher := headerMatcher{}
    		// we will raise a panic for the first request.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Oct 30 12:18:40 UTC 2023
    - 52.6K bytes
    - Viewed (0)
  8. pilot/pkg/config/kube/ingress/status.go

    	pods           kclient.Client[*corev1.Pod]
    	services       kclient.Client[*corev1.Service]
    	nodes          kclient.Client[*corev1.Node]
    }
    
    // Run the syncer until stopCh is closed
    func (s *StatusSyncer) Run(stopCh <-chan struct{}) {
    	s.queue.Run(stopCh)
    	controllers.ShutdownAll(s.services, s.nodes, s.pods, s.ingressClasses, s.ingresses)
    }
    
    // NewStatusSyncer creates a new instance
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Feb 28 16:41:38 UTC 2024
    - 7.9K bytes
    - Viewed (0)
  9. staging/src/k8s.io/apiserver/pkg/server/dynamiccertificates/dynamic_serving_content.go

    	// start the loop that watches the cert and key files until stopCh is closed.
    	go wait.Until(func() {
    		if err := c.watchCertKeyFile(ctx.Done()); err != nil {
    			klog.ErrorS(err, "Failed to watch cert and key file, will retry later")
    		}
    	}, time.Minute, ctx.Done())
    
    	<-ctx.Done()
    }
    
    func (c *DynamicCertKeyPairContent) watchCertKeyFile(stopCh <-chan struct{}) error {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 6.9K bytes
    - Viewed (0)
  10. pkg/controlplane/controller/crdregistration/crdregistration_controller.go

    		go wait.Until(c.runWorker, time.Second, stopCh)
    	}
    
    	// wait until we're told to stop
    	<-stopCh
    }
    
    // WaitForInitialSync blocks until the initial set of CRD resources has been processed
    func (c *crdRegistrationController) WaitForInitialSync() {
    	<-c.syncedInitialSet
    }
    
    func (c *crdRegistrationController) runWorker() {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 8.3K bytes
    - Viewed (0)
Back to top