- Sort Score
- Result 10 results
- Languages All
Results 21 - 24 of 24 for DeleteFunc (0.24 sec)
-
staging/src/k8s.io/apiserver/pkg/server/dynamiccertificates/configmap_cafile_content.go
// so we don't have to be choosy about our key. AddFunc: func(obj interface{}) { c.queue.Add(c.keyFn()) }, UpdateFunc: func(oldObj, newObj interface{}) { c.queue.Add(c.keyFn()) }, DeleteFunc: func(obj interface{}) { c.queue.Add(c.keyFn()) }, }, }) return c, nil } func (c *ConfigMapCAController) keyFn() string {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 8.9K bytes - Viewed (0) -
pkg/controller/volume/ephemeral/controller.go
// Deletion of the PVC is handled through the owner reference and garbage collection. // Therefore pod deletions also can be ignored. }) pvcInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{ DeleteFunc: ec.onPVCDelete, }) if err := common.AddPodPVCIndexerIfNotPresent(ec.podIndexer); err != nil { return nil, fmt.Errorf("could not initialize ephemeral volume controller: %w", err) } return ec, nil }
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/controller/ttl/ttl_controller.go
AddFunc: func(obj interface{}) { ttlc.addNode(logger, obj) }, UpdateFunc: func(old, newObj interface{}) { ttlc.updateNode(logger, old, newObj) }, DeleteFunc: ttlc.deleteNode, }) ttlc.nodeStore = listers.NewNodeLister(nodeInformer.Informer().GetIndexer()) ttlc.hasSynced = nodeInformer.Informer().HasSynced return ttlc } type ttlBoundary struct {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 8.5K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/controller/openapi/controller.go
specsByName: map[string]*specCache{}, } crdInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{ AddFunc: c.addCustomResourceDefinition, UpdateFunc: c.updateCustomResourceDefinition, DeleteFunc: c.deleteCustomResourceDefinition, }) c.syncFn = c.sync return c } // Run sets openAPIAggregationManager and starts workers
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 9.6K bytes - Viewed (0)