- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 21 for DeletionHandlingMetaNamespaceKeyFunc (0.6 sec)
-
pkg/registry/core/service/ipallocator/controller/repairip.go
r.svcQueue.Add(key) } }, DeleteFunc: func(obj interface{}) { // IndexerInformer uses a delta queue, therefore for deletes we have to use this // key function. key, err := cache.DeletionHandlingMetaNamespaceKeyFunc(obj) if err == nil { r.svcQueue.Add(key) } }, }, interval) _, _ = serviceCIDRInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 24.7K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/controller/apiapproval/apiapproval_controller.go
c.queue.AddRateLimited(key) return true } func (c *KubernetesAPIApprovalPolicyConformantConditionController) enqueue(obj *apiextensionsv1.CustomResourceDefinition) { key, err := cache.DeletionHandlingMetaNamespaceKeyFunc(obj) if err != nil { utilruntime.HandleError(fmt.Errorf("Couldn't get key for object %#v: %v", obj, err)) return } c.queue.Add(key) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 9.2K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/controller/nonstructuralschema/nonstructuralschema_controller.go
c.queue.AddRateLimited(key) return true } func (c *ConditionController) enqueue(obj *apiextensionsv1.CustomResourceDefinition) { key, err := cache.DeletionHandlingMetaNamespaceKeyFunc(obj) if err != nil { utilruntime.HandleError(fmt.Errorf("couldn't get key for object %#v: %v", obj, err)) return } c.queue.Add(key) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 8.3K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/dynamiccertificates/configmap_cafile_content.go
DeleteFunc: func(obj interface{}) { c.queue.Add(c.keyFn()) }, }, }) return c, nil } func (c *ConfigMapCAController) keyFn() string { // this format matches DeletionHandlingMetaNamespaceKeyFunc for our single key return c.configmapNamespace + "/" + c.configmapName } // AddListener adds a listener to be notified when the CA content changes.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 8.9K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/authentication/request/headerrequest/requestheader_controller.go
case c.allowedClientNamesKey: return headerBundle.AllowedClientNames default: return nil } } func (c *RequestHeaderAuthRequestController) keyFn() string { // this format matches DeletionHandlingMetaNamespaceKeyFunc for our single key return c.configmapNamespace + "/" + c.configmapName } func deserializeStrings(in string) ([]string, error) { if len(in) == 0 { return nil, nil } var ret []string
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 10.9K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/policy/internal/generic/controller.go
// would never shut down the workqueue defer c.queue.ShutDown() enqueue := func(obj interface{}, isInInitialList bool) { var key string var err error if key, err = cache.DeletionHandlingMetaNamespaceKeyFunc(obj); err != nil { utilruntime.HandleError(err) return } if isInInitialList { c.hasProcessed.Start(key) } c.queue.Add(key) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 7.5K bytes - Viewed (0) -
pkg/controller/volume/ephemeral/controller.go
return } for _, vol := range pod.Spec.Volumes { if vol.Ephemeral != nil { // It has at least one ephemeral inline volume, work on it. key, err := cache.DeletionHandlingMetaNamespaceKeyFunc(pod) if err != nil { runtime.HandleError(fmt.Errorf("couldn't get key for object %#v: %v", pod, err)) return } ec.queue.Add(key) break } } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 9.2K bytes - Viewed (0) -
pkg/registry/core/service/ipallocator/cidrallocator.go
key, err := cache.MetaNamespaceKeyFunc(new) if err == nil { c.queue.Add(key) } } func (c *MetaAllocator) deleteServiceCIDR(obj interface{}) { key, err := cache.DeletionHandlingMetaNamespaceKeyFunc(obj) if err == nil { c.queue.Add(key) } } func (c *MetaAllocator) run() { defer runtime.HandleCrash() defer c.queue.ShutDown()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 13.2K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/controller/finalizer/crd_finalizer.go
c.queue.AddRateLimited(key) return true } func (c *CRDFinalizer) enqueue(obj *apiextensionsv1.CustomResourceDefinition) { key, err := cache.DeletionHandlingMetaNamespaceKeyFunc(obj) if err != nil { utilruntime.HandleError(fmt.Errorf("couldn't get key for object %#v: %v", obj, err)) return } c.queue.Add(key) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 12.6K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/controller/status/naming_controller.go
c.queue.AddRateLimited(key) return true } func (c *NamingConditionController) enqueue(obj *apiextensionsv1.CustomResourceDefinition) { key, err := cache.DeletionHandlingMetaNamespaceKeyFunc(obj) if err != nil { utilruntime.HandleError(fmt.Errorf("couldn't get key for object %#v: %v", obj, err)) return } c.queue.Add(key) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 13.2K bytes - Viewed (0)