Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 39 for DeleteFunc (0.17 sec)

  1. pkg/controller/endpoint/endpoints_controller.go

    		UpdateFunc: func(old, cur interface{}) {
    			e.onServiceUpdate(cur)
    		},
    		DeleteFunc: e.onServiceDelete,
    	})
    	e.serviceLister = serviceInformer.Lister()
    	e.servicesSynced = serviceInformer.Informer().HasSynced
    
    	podInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{
    		AddFunc:    e.addPod,
    		UpdateFunc: e.updatePod,
    		DeleteFunc: e.deletePod,
    	})
    	e.podLister = podInformer.Lister()
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 26.3K bytes
    - Viewed (0)
  2. operator/pkg/controller/istiocontrolplane/istiocontrolplane_controller.go

    			// no action
    			return false
    		},
    		GenericFunc: func(_ event.TypedGenericEvent[*unstructured.Unstructured]) bool {
    			// no action
    			return false
    		},
    		DeleteFunc: func(e event.TypedDeleteEvent[*unstructured.Unstructured]) bool {
    			obj, err := meta.Accessor(e.Object)
    			if err != nil {
    				return false
    			}
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Apr 30 13:56:46 UTC 2024
    - 19.4K bytes
    - Viewed (0)
  3. pkg/controller/serviceaccount/tokens_controller.go

    	serviceAccounts.Informer().AddEventHandlerWithResyncPeriod(
    		cache.ResourceEventHandlerFuncs{
    			AddFunc:    e.queueServiceAccountSync,
    			UpdateFunc: e.queueServiceAccountUpdateSync,
    			DeleteFunc: e.queueServiceAccountSync,
    		},
    		options.ServiceAccountResync,
    	)
    
    	secretCache := secrets.Informer().GetIndexer()
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 20.5K bytes
    - Viewed (0)
  4. pkg/controller/statefulset/stateful_set.go

    		// lookup current and old statefulset if labels changed
    		UpdateFunc: func(oldObj, newObj interface{}) {
    			ssc.updatePod(logger, oldObj, newObj)
    		},
    		// lookup statefulset accounting for deletion tombstones
    		DeleteFunc: func(obj interface{}) {
    			ssc.deletePod(logger, obj)
    		},
    	})
    	ssc.podLister = podInformer.Lister()
    	ssc.podListerSynced = podInformer.Informer().HasSynced
    
    	setInformer.Informer().AddEventHandler(
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 05 19:06:41 UTC 2024
    - 18.5K bytes
    - Viewed (0)
  5. pkg/controller/storageversiongc/gc_controller.go

    		),
    	}
    	logger := klog.FromContext(ctx)
    	leaseInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{
    		DeleteFunc: func(obj interface{}) {
    			c.onDeleteLease(logger, obj)
    		},
    	})
    	// use the default resync period from the informer
    	storageVersionInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 10K bytes
    - Viewed (0)
  6. staging/src/k8s.io/apiserver/pkg/authentication/request/headerrequest/requestheader_controller.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())
    			},
    		},
    	})
    
    	c.configmapLister = corev1listers.NewConfigMapLister(c.configmapInformer.GetIndexer()).ConfigMaps(c.configmapNamespace)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 10.9K bytes
    - Viewed (0)
  7. staging/src/k8s.io/apiextensions-apiserver/pkg/apiserver/customresource_discovery_controller.go

    		),
    	}
    
    	crdInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{
    		AddFunc:    c.addCustomResourceDefinition,
    		UpdateFunc: c.updateCustomResourceDefinition,
    		DeleteFunc: c.deleteCustomResourceDefinition,
    	})
    
    	c.syncFn = c.sync
    
    	return c
    }
    
    func (c *DiscoveryController) sync(version schema.GroupVersion) error {
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sun Apr 21 11:40:03 UTC 2024
    - 12.8K bytes
    - Viewed (0)
  8. staging/src/k8s.io/apiextensions-apiserver/pkg/controller/status/naming_controller.go

    	crdInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{
    		AddFunc:    c.addCustomResourceDefinition,
    		UpdateFunc: c.updateCustomResourceDefinition,
    		DeleteFunc: c.deleteCustomResourceDefinition,
    	})
    
    	c.syncFn = c.sync
    
    	return c
    }
    
    func (c *NamingConditionController) getAcceptedNamesForGroup(group string) (allResources sets.String, allKinds sets.String) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 13.2K bytes
    - Viewed (0)
  9. pkg/scheduler/util/assumecache/assume_cache.go

    	if informer != nil {
    		// Cannot fail in practice?! No-one bothers checking the error.
    		_, _ = informer.AddEventHandler(
    			cache.ResourceEventHandlerFuncs{
    				AddFunc:    c.add,
    				UpdateFunc: c.update,
    				DeleteFunc: c.delete,
    			},
    		)
    	}
    	return c
    }
    
    func (c *AssumeCache) add(obj interface{}) {
    	if obj == nil {
    		return
    	}
    
    	name, err := cache.MetaNamespaceKeyFunc(obj)
    	if err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 25 09:46:58 UTC 2024
    - 10.6K bytes
    - Viewed (0)
  10. pkg/controller/volume/persistentvolume/pv_controller_base.go

    			AddFunc:    func(obj interface{}) { controller.enqueueWork(ctx, controller.volumeQueue, obj) },
    			UpdateFunc: func(oldObj, newObj interface{}) { controller.enqueueWork(ctx, controller.volumeQueue, newObj) },
    			DeleteFunc: func(obj interface{}) { controller.enqueueWork(ctx, controller.volumeQueue, obj) },
    		},
    	)
    	controller.volumeLister = p.VolumeInformer.Lister()
    	controller.volumeListerSynced = p.VolumeInformer.Informer().HasSynced
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 10 08:42:31 UTC 2024
    - 29.5K bytes
    - Viewed (0)
Back to top