- Sort Score
- Result 10 results
- Languages All
Results 101 - 110 of 131 for UpdateFunc (0.25 sec)
-
pilot/pkg/config/kube/crdclient/client.go
AddFunc: func(obj controllers.Object) { incrementEvent(kind, "add") cl.queue.Push(func() error { cl.onEvent(resourceGVK, nil, obj, model.EventAdd) return nil }) }, UpdateFunc: func(old, cur controllers.Object) { incrementEvent(kind, "update") cl.queue.Push(func() error { cl.onEvent(resourceGVK, old, cur, model.EventUpdate) return nil }) },
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 00:12:28 UTC 2024 - 13.7K bytes - Viewed (0) -
pilot/pkg/config/kube/gateway/controller.go
domain: options.DomainSuffix, statusController: atomic.NewPointer(ctl), waitForCRD: waitForCRD, } namespaces.AddEventHandler(controllers.EventHandler[*corev1.Namespace]{ UpdateFunc: func(oldNs, newNs *corev1.Namespace) { if !labels.Instance(oldNs.Labels).Equals(newNs.Labels) { gatewayController.namespaceEvent(oldNs, newNs) } }, }) if credsController != nil {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sat Mar 30 05:26:03 UTC 2024 - 13.5K bytes - Viewed (0) -
pkg/controller/endpoint/endpoints_controller.go
AddFunc: e.onServiceUpdate, UpdateFunc: func(old, cur interface{}) { e.onServiceUpdate(cur) }, DeleteFunc: e.onServiceDelete, }) e.serviceLister = serviceInformer.Lister() e.servicesSynced = serviceInformer.Informer().HasSynced podInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{ AddFunc: e.addPod, UpdateFunc: e.updatePod, DeleteFunc: e.deletePod, })
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 26.3K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/etcd3/store.go
func (s *store) GuaranteedUpdate( ctx context.Context, key string, destination runtime.Object, ignoreNotFound bool, preconditions *storage.Preconditions, tryUpdate storage.UpdateFunc, cachedExistingObject runtime.Object) error { preparedKey, err := s.prepareKey(key) if err != nil { return err } ctx, span := tracing.Start(ctx, "GuaranteedUpdate etcd3",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 10 11:56:42 UTC 2024 - 35.2K bytes - Viewed (0) -
pkg/controller/volume/expand/expand_controller.go
kubeClient, &expc.volumePluginMgr, expc.recorder, blkutil) pvcInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{ AddFunc: expc.enqueuePVC, UpdateFunc: func(old, new interface{}) { oldPVC, ok := old.(*v1.PersistentVolumeClaim) if !ok { return } oldReq := oldPVC.Spec.Resources.Requests[v1.ResourceStorage]
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 16.2K bytes - Viewed (0) -
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) -
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/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)