Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 33 of 33 for DeleteFunc (0.24 sec)

  1. 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)
  2. 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)
  3. 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)
Back to top