- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 38 for DeleteFunc (0.17 sec)
-
pkg/controller/resourcequota/resource_quota_monitor.go
event := &event{ eventType: updateEvent, obj: newObj, oldObj: oldObj, gvr: resource, } qm.resourceChanges.Add(event) } }, DeleteFunc: func(obj interface{}) { // delta fifo may wrap the object in a cache.DeletedFinalStateUnknown, unwrap it if deletedFinalStateUnknown, ok := obj.(cache.DeletedFinalStateUnknown); ok { obj = deletedFinalStateUnknown.Obj
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 11.6K bytes - Viewed (0) -
pkg/registry/core/service/ipallocator/cidrallocator.go
ipFamily: family, } _, _ = serviceCIDRInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{ AddFunc: c.addServiceCIDR, UpdateFunc: c.updateServiceCIDR, DeleteFunc: c.deleteServiceCIDR, }) go c.run() return c, nil } func (c *MetaAllocator) addServiceCIDR(obj interface{}) { key, err := cache.MetaNamespaceKeyFunc(obj) if err == nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 13.2K bytes - Viewed (0) -
pilot/pkg/config/kube/crdclient/client.go
UpdateFunc: func(old, cur controllers.Object) { incrementEvent(kind, "update") cl.queue.Push(func() error { cl.onEvent(resourceGVK, old, cur, model.EventUpdate) return nil }) }, DeleteFunc: func(obj controllers.Object) { incrementEvent(kind, "delete") cl.queue.Push(func() error { cl.onEvent(resourceGVK, nil, obj, model.EventDelete) 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) -
pkg/controller/volume/attachdetach/attach_detach_controller.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 32.6K bytes - Viewed (0) -
pkg/controller/volume/expand/expand_controller.go
if newReq.Cmp(oldReq) > 0 || newCap.Cmp(oldCap) > 0 { expc.enqueuePVC(new) } }, DeleteFunc: expc.enqueuePVC, }) return expc, nil } func (expc *expandController) enqueuePVC(obj interface{}) { pvc, ok := obj.(*v1.PersistentVolumeClaim) if !ok { return }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 16.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 } 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/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) -
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/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/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)