Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 1,038 for stopCh (0.12 sec)

  1. 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)
  2. staging/src/k8s.io/apiextensions-apiserver/pkg/controller/establish/establishing_controller.go

    }
    
    // Run starts the EstablishingController.
    func (ec *EstablishingController) Run(stopCh <-chan struct{}) {
    	defer utilruntime.HandleCrash()
    	defer ec.queue.ShutDown()
    
    	klog.Info("Starting EstablishingController")
    	defer klog.Info("Shutting down EstablishingController")
    
    	if !cache.WaitForCacheSync(stopCh, ec.crdSynced) {
    		return
    	}
    
    	// only start one worker thread since its a slow moving API
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 4.4K bytes
    - Viewed (0)
  3. staging/src/k8s.io/apiserver/pkg/storage/cacher/watch_progress.go

    	cond    *sync.Cond
    	waiting int
    	stopped bool
    }
    
    func (pr *conditionalProgressRequester) Run(stopCh <-chan struct{}) {
    	ctx := wait.ContextForChannel(stopCh)
    	if pr.contextMetadata != nil {
    		ctx = metadata.NewOutgoingContext(ctx, pr.contextMetadata)
    	}
    	go func() {
    		defer utilruntime.HandleCrash()
    		<-stopCh
    		pr.mux.Lock()
    		defer pr.mux.Unlock()
    		pr.stopped = true
    		pr.cond.Signal()
    	}()
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 24 09:56:38 UTC 2024
    - 3K bytes
    - Viewed (0)
  4. pkg/controlplane/controller/legacytokentracking/controller.go

    // Run starts the controller sync loop.
    func (c *Controller) Run(stopCh <-chan struct{}) {
    	defer utilruntime.HandleCrash()
    	defer c.queue.ShutDown()
    
    	klog.Info("Starting legacy_token_tracking_controller")
    	defer klog.Infof("Shutting down legacy_token_tracking_controller")
    
    	go c.configMapInformer.Run(stopCh)
    	if !cache.WaitForNamedCacheSync("configmaps", stopCh, c.configMapSynced) {
    		return
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 6K bytes
    - Viewed (0)
  5. pkg/controlplane/controller/systemnamespaces/system_namespaces_controller.go

    		interval:         interval,
    	}
    }
    
    // Run starts one worker.
    func (c *Controller) Run(stopCh <-chan struct{}) {
    	defer utilruntime.HandleCrash()
    	defer klog.Infof("Shutting down system namespaces controller")
    
    	klog.Infof("Starting system namespaces controller")
    
    	if !cache.WaitForCacheSync(stopCh, c.namespaceSynced) {
    		utilruntime.HandleError(fmt.Errorf("timed out waiting for caches to sync"))
    		return
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Apr 27 12:19:56 UTC 2024
    - 2.9K bytes
    - Viewed (0)
  6. 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)
  7. pkg/revisions/tag_watcher.go

    			}
    			return []string{rev}
    		}, controllers.ObjectHandler(p.queue.AddObject))
    	return p
    }
    
    func (p *tagWatcher) Run(stopCh <-chan struct{}) {
    	if !kube.WaitForCacheSync("tag watcher", stopCh, p.webhooks.HasSynced) {
    		return
    	}
    	// Notify handlers of initial state
    	p.notifyHandlers()
    	p.queue.Run(stopCh)
    }
    
    // AddHandler registers a new handler for updates to tag changes.
    func (p *tagWatcher) AddHandler(handler TagHandler) {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Jun 14 00:12:28 UTC 2024
    - 3.3K bytes
    - Viewed (0)
  8. 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)
  9. staging/src/k8s.io/apiserver/pkg/storage/storagebackend/factory/factory.go

    func CreateHealthCheck(c storagebackend.Config, stopCh <-chan struct{}) (func() error, error) {
    	switch c.Type {
    	case storagebackend.StorageTypeETCD2:
    		return nil, fmt.Errorf("%s is no longer a supported storage backend", c.Type)
    	case storagebackend.StorageTypeUnset, storagebackend.StorageTypeETCD3:
    		return newETCD3HealthCheck(c, stopCh)
    	default:
    		return nil, fmt.Errorf("unknown storage type: %s", c.Type)
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Aug 24 09:23:05 UTC 2023
    - 3.3K bytes
    - Viewed (0)
  10. 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)
Back to top