- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of 79 for DeleteFunc (0.19 sec)
-
pkg/controller/cronjob/cronjob_controllerv2.go
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) }, DeleteFunc: func(obj interface{}) { jm.enqueueController(obj) }, })
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 09 03:34:25 UTC 2024 - 29.2K bytes - Viewed (0) -
pkg/controller/volume/pvcprotection/pvc_protection_controller.go
} podInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{ AddFunc: func(obj interface{}) { e.podAddedDeletedUpdated(logger, nil, obj, false) }, DeleteFunc: func(obj interface{}) { e.podAddedDeletedUpdated(logger, nil, obj, true) }, UpdateFunc: func(old, new interface{}) { e.podAddedDeletedUpdated(logger, old, new, false) }, }) return e, nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 14K 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 } defer func() {
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/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/nodeipam/ipam/range_allocator.go
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{}) { // The informer cache no longer has the object, and since Node doesn't have a finalizer, // we don't see the Update with DeletionTimestamp != 0.
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/controller/disruption/disruption.go
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() dc.podListerSynced = podInformer.Informer().HasSynced
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
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{ controllerUIDIndex: func(obj interface{}) ([]string, error) { rs, ok := obj.(*apps.ReplicaSet)
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/kubelet/cm/dra/plugin/noderesources.go
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
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 } if _, err := claimInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 09 03:34:25 UTC 2024 - 37.1K bytes - Viewed (0) -
src/crypto/tls/common.go
if needFIPS() { return slices.DeleteFunc(curvePreferences, func(c CurveID) bool { return !slices.Contains(defaultCurvePreferencesFIPS, c) }) } } else if needFIPS() { curvePreferences = slices.Clone(defaultCurvePreferencesFIPS) } else { curvePreferences = defaultCurvePreferences() } if version < VersionTLS13 { return slices.DeleteFunc(curvePreferences, func(c CurveID) bool {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 03:10:12 UTC 2024 - 59.1K bytes - Viewed (0)