Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for HasSynced (0.36 sec)

  1. pkg/controller/daemon/daemon_controller.go

    	dsc.podStoreSynced = podInformer.Informer().HasSynced
    
    	nodeInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{
    		AddFunc: func(obj interface{}) {
    			dsc.addNode(logger, obj)
    		},
    		UpdateFunc: func(oldObj, newObj interface{}) {
    			dsc.updateNode(logger, oldObj, newObj)
    		},
    	},
    	)
    	dsc.nodeStoreSynced = nodeInformer.Informer().HasSynced
    	dsc.nodeLister = nodeInformer.Lister()
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 51.3K bytes
    - Viewed (0)
  2. pkg/controller/nodelifecycle/node_lifecycle_controller.go

    			return nil
    		}),
    	})
    
    	nc.leaseLister = leaseInformer.Lister()
    	nc.leaseInformerSynced = leaseInformer.Informer().HasSynced
    
    	nc.nodeInformerSynced = nodeInformer.Informer().HasSynced
    
    	nc.daemonSetStore = daemonSetInformer.Lister()
    	nc.daemonSetInformerSynced = daemonSetInformer.Informer().HasSynced
    
    	return nc, nil
    }
    
    // Run starts an asynchronous loop that monitors the status of cluster nodes.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 51.6K bytes
    - Viewed (0)
  3. pkg/controller/podautoscaler/horizontal.go

    		},
    		resyncPeriod,
    	)
    	hpaController.hpaLister = hpaInformer.Lister()
    	hpaController.hpaListerSynced = hpaInformer.Informer().HasSynced
    
    	hpaController.podLister = podInformer.Lister()
    	hpaController.podListerSynced = podInformer.Informer().HasSynced
    
    	replicaCalc := NewReplicaCalculator(
    		metricsClient,
    		hpaController.podLister,
    		tolerance,
    		cpuInitializationPeriod,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 63.6K bytes
    - Viewed (0)
  4. pkg/controller/job/job_controller.go

    			jm.deleteJob(logger, obj)
    		},
    	}); err != nil {
    		return nil, fmt.Errorf("adding Job event handler: %w", err)
    	}
    	jm.jobLister = jobInformer.Lister()
    	jm.jobStoreSynced = jobInformer.Informer().HasSynced
    
    	if _, err := podInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{
    		AddFunc: func(obj interface{}) {
    			jm.addPod(logger, obj)
    		},
    		UpdateFunc: func(oldObj, newObj interface{}) {
    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