- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 26 for DeletionHandlingMetaNamespaceKeyFunc (0.4 sec)
-
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) -
pkg/scheduler/util/assumecache/assume_cache.go
func (c *AssumeCache) update(oldObj interface{}, newObj interface{}) { c.add(newObj) } func (c *AssumeCache) delete(obj interface{}) { if obj == nil { return } name, err := cache.DeletionHandlingMetaNamespaceKeyFunc(obj) if err != nil { c.logger.Error(&ObjectNameError{err}, "Failed to delete") return } c.rwMutex.Lock() defer c.rwMutex.Unlock() objInfo := &objInfo{name: name}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 25 09:46:58 UTC 2024 - 10.6K bytes - Viewed (0) -
pkg/controlplane/controller/clusterauthenticationtrust/cluster_authentication_trust_controller.go
// calm down or it can starve other useful work) cases. c.queue.AddRateLimited(key) return true } func keyFn() string { // this format matches DeletionHandlingMetaNamespaceKeyFunc for our single key return configMapNamespace + "/" + configMapName } func encodeCertificates(certs ...*x509.Certificate) ([]byte, error) { b := bytes.Buffer{} for _, cert := range certs {
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/testutil/test_utils.go
api "k8s.io/kubernetes/pkg/apis/core" "k8s.io/utils/clock" testingclock "k8s.io/utils/clock/testing" jsonpatch "gopkg.in/evanphx/json-patch.v4" ) var ( keyFunc = cache.DeletionHandlingMetaNamespaceKeyFunc ) // FakeNodeHandler is a fake implementation of NodesInterface and NodeInterface. It // allows test cases to have fine-grained control over mock behaviors. We also need
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 28 08:48:22 UTC 2024 - 15.6K bytes - Viewed (0) -
pkg/controller/volume/expand/expand_controller.go
func (expc *expandController) enqueuePVC(obj interface{}) { pvc, ok := obj.(*v1.PersistentVolumeClaim) if !ok { return } if pvc.Status.Phase == v1.ClaimBound { key, err := cache.DeletionHandlingMetaNamespaceKeyFunc(pvc) if err != nil { runtime.HandleError(fmt.Errorf("couldn't get key for object %#v: %v", pvc, err)) return } expc.queue.Add(key) } }
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/controller/volume/persistentvolume/pv_controller_test.go
} } } // TestControllerCache tests func storeObjectUpdate() func TestControllerCache(t *testing.T) { // Cache under test c := cache.NewStore(cache.DeletionHandlingMetaNamespaceKeyFunc) // Store new PV storeVersion(t, "Step1", c, "1", true) // Store the same PV storeVersion(t, "Step2", c, "1", true) // Store newer PV storeVersion(t, "Step3", c, "2", true)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 43.4K bytes - Viewed (0) -
pkg/controller/servicecidrs/servicecidrs_controller.go
key, err := cache.MetaNamespaceKeyFunc(obj) if err == nil { c.queue.Add(key) } } // deleteServiceCIDR func (c *Controller) deleteServiceCIDR(obj interface{}) { key, err := cache.DeletionHandlingMetaNamespaceKeyFunc(obj) if err == nil { c.queue.Add(key) } } // addIPAddress may block a ServiceCIDR deletion func (c *Controller) addIPAddress(obj interface{}) {
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
} // IndexerInformer uses a delta nodeQueue, therefore for deletes we have to use this // key function. key, err := cache.DeletionHandlingMetaNamespaceKeyFunc(obj) if err == nil { ra.queue.Add(key) } }, }) return ra, nil } func (r *rangeAllocator) Run(ctx context.Context) { defer utilruntime.HandleCrash()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 10:06:15 UTC 2024 - 16.2K bytes - Viewed (0)