Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for WaitForNamedCacheSync (0.34 sec)

  1. pkg/controller/podautoscaler/replica_calculator_test.go

    	stop := make(chan struct{})
    	defer close(stop)
    	informerFactory.Start(stop)
    	if !cache.WaitForNamedCacheSync("HPA", stop, informer.Informer().HasSynced) {
    		return
    	}
    
    	selector, err := metav1.LabelSelectorAsSelector(&metav1.LabelSelector{
    		MatchLabels: map[string]string{"name": podNamePrefix},
    	})
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Aug 19 03:31:34 UTC 2023
    - 68.4K bytes
    - Viewed (0)
  2. pkg/controller/daemon/daemon_controller.go

    	defer dsc.queue.ShutDown()
    
    	logger := klog.FromContext(ctx)
    	logger.Info("Starting daemon sets controller")
    	defer logger.Info("Shutting down daemon sets controller")
    
    	if !cache.WaitForNamedCacheSync("daemon sets", ctx.Done(), dsc.podStoreSynced, dsc.nodeStoreSynced, dsc.historyStoreSynced, dsc.dsStoreSynced) {
    		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
    - 51.3K bytes
    - Viewed (0)
  3. pkg/controller/nodelifecycle/node_lifecycle_controller.go

    	defer nc.nodeUpdateQueue.ShutDown()
    	defer nc.podUpdateQueue.ShutDown()
    
    	logger.Info("Starting node controller")
    	defer logger.Info("Shutting down node controller")
    
    	if !cache.WaitForNamedCacheSync("taint", ctx.Done(), nc.leaseInformerSynced, nc.nodeInformerSynced, nc.podInformerSynced, nc.daemonSetInformerSynced) {
    		return
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 51.6K bytes
    - Viewed (0)
  4. pkg/controller/podautoscaler/horizontal.go

    	defer utilruntime.HandleCrash()
    	defer a.queue.ShutDown()
    
    	logger := klog.FromContext(ctx)
    	logger.Info("Starting HPA controller")
    	defer logger.Info("Shutting down HPA controller")
    
    	if !cache.WaitForNamedCacheSync("HPA", ctx.Done(), a.hpaListerSynced, a.podListerSynced) {
    		return
    	}
    
    	for i := 0; i < workers; i++ {
    		go wait.UntilWithContext(ctx, a.worker, time.Second)
    	}
    
    	<-ctx.Done()
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 63.6K bytes
    - Viewed (0)
  5. pkg/controller/endpoint/endpoints_controller_test.go

    			endpoints.servicesSynced = test.servicesSynced
    			endpoints.endpointsSynced = test.endpointsSynced
    			endpoints.workerLoopPeriod = 10 * time.Millisecond
    			go endpoints.Run(tCtx, 1)
    
    			// cache.WaitForNamedCacheSync has a 100ms poll period, and the endpoints worker has a 10ms period.
    			// To ensure we get all updates, including unexpected ones, we need to wait at least as long as
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Feb 26 06:51:56 UTC 2024
    - 87.7K bytes
    - Viewed (0)
  6. pkg/controller/job/job_controller.go

    	defer jm.broadcaster.Shutdown()
    
    	defer jm.queue.ShutDown()
    	defer jm.orphanQueue.ShutDown()
    
    	logger.Info("Starting job controller")
    	defer logger.Info("Shutting down job controller")
    
    	if !cache.WaitForNamedCacheSync("job", ctx.Done(), jm.podStoreSynced, jm.jobStoreSynced) {
    		return
    	}
    
    	for i := 0; i < workers; i++ {
    		go wait.UntilWithContext(ctx, jm.worker, time.Second)
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Jun 10 23:56:37 UTC 2024
    - 77.6K bytes
    - Viewed (0)
Back to top