- Sort Score
- Result 10 results
- Languages All
Results 1 - 4 of 4 for HasSynced (0.36 sec)
-
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) -
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) -
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) -
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)