- Sort Score
- Result 10 results
- Languages All
Results 71 - 80 of 94 for UpdateFunc (0.36 sec)
-
pkg/controlplane/controller/clusterauthenticationtrust/cluster_authentication_trust_controller.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 18.2K bytes - Viewed (0) -
pkg/controller/disruption/disruption.go
dc.getUpdater = func() updater { return dc.writePdbStatus } podInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{ AddFunc: func(obj interface{}) { dc.addPod(logger, obj) }, UpdateFunc: func(oldObj, newObj interface{}) { dc.updatePod(logger, oldObj, newObj) }, DeleteFunc: func(obj interface{}) { dc.deletePod(logger, obj) }, }) dc.podLister = podInformer.Lister()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 36.1K bytes - Viewed (0) -
pkg/controller/replicaset/replica_set.go
), } rsInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{ AddFunc: func(obj interface{}) { rsc.addRS(logger, obj) }, UpdateFunc: func(oldObj, newObj interface{}) { rsc.updateRS(logger, oldObj, newObj) }, DeleteFunc: func(obj interface{}) { rsc.deleteRS(logger, obj) }, }) rsInformer.Informer().AddIndexers(cache.Indexers{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 33.2K bytes - Viewed (0) -
pkg/controller/cronjob/cronjob_controllerv2.go
jobInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{ AddFunc: jm.addJob, UpdateFunc: jm.updateJob, DeleteFunc: jm.deleteJob, }) cronJobsInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{ AddFunc: func(obj interface{}) { jm.enqueueController(obj) }, UpdateFunc: func(oldObj, newObj interface{}) { jm.updateCronJob(logger, oldObj, newObj) },
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 09 03:34:25 UTC 2024 - 29.2K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/policy/generic/policy_source.go
s.notify() s.refreshPolicies() notifyFuncs := cache.ResourceEventHandlerFuncs{ AddFunc: func(_ interface{}) { s.notify() }, UpdateFunc: func(_, _ interface{}) { s.notify() }, DeleteFunc: func(_ interface{}) { s.notify() }, } handle, err := s.policyInformer.AddEventHandler(notifyFuncs) if err != nil { return err
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Feb 21 23:07:34 UTC 2024 - 15.2K bytes - Viewed (0) -
pkg/controller/servicecidrs/servicecidrs_controller.go
), tree: iptree.New[sets.Set[string]](), workerLoopPeriod: time.Second, } _, _ = serviceCIDRInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{ AddFunc: c.addServiceCIDR, UpdateFunc: c.updateServiceCIDR, DeleteFunc: c.deleteServiceCIDR, }) c.serviceCIDRLister = serviceCIDRInformer.Lister() c.serviceCIDRsSynced = serviceCIDRInformer.Informer().HasSynced
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 18K bytes - Viewed (0) -
pkg/controller/nodeipam/ipam/range_allocator.go
nodeInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{ AddFunc: func(obj interface{}) { key, err := cache.MetaNamespaceKeyFunc(obj) if err == nil { ra.queue.Add(key) } }, UpdateFunc: func(old, new interface{}) { key, err := cache.MetaNamespaceKeyFunc(new) if err == nil { ra.queue.Add(key) } }, DeleteFunc: func(obj interface{}) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 10:06:15 UTC 2024 - 16.2K bytes - Viewed (0) -
pkg/kubelet/cm/dra/plugin/noderesources.go
slice, ok := obj.(*resourceapi.ResourceSlice) if !ok { return } logger.V(5).Info("ResourceSlice add", "slice", klog.KObj(slice)) c.queue.Add(slice.DriverName) }, UpdateFunc: func(old, new any) { oldSlice, ok := old.(*resourceapi.ResourceSlice) if !ok { return } newSlice, ok := new.(*resourceapi.ResourceSlice) if !ok { return }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 27 20:12:53 UTC 2024 - 16.6K bytes - Viewed (0) -
pkg/controller/resourceclaim/controller.go
} metrics.RegisterMetrics() if _, err := podInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{ AddFunc: func(obj interface{}) { ec.enqueuePod(logger, obj, false) }, UpdateFunc: func(old, updated interface{}) { ec.enqueuePod(logger, updated, false) }, DeleteFunc: func(obj interface{}) { ec.enqueuePod(logger, obj, true) }, }); err != nil { return nil, err }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 09 03:34:25 UTC 2024 - 37.1K bytes - Viewed (0) -
pkg/controller/resourcequota/resource_quota_controller.go
options.ResourceQuotaInformer.Informer().AddEventHandlerWithResyncPeriod( cache.ResourceEventHandlerFuncs{ AddFunc: func(obj interface{}) { rq.addQuota(logger, obj) }, UpdateFunc: func(old, cur interface{}) { // We are only interested in observing updates to quota.spec to drive updates to quota.status. // We ignore all updates to quota.Status because they are all driven by this controller.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 21.3K bytes - Viewed (0)