- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 79 for DeleteFunc (0.16 sec)
-
pkg/registry/core/service/ipallocator/controller/repairip.go
r.svcQueue.Add(key) } }, UpdateFunc: func(old interface{}, new interface{}) { key, err := cache.MetaNamespaceKeyFunc(new) if err == nil { 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 {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 24.7K bytes - Viewed (0) -
pkg/controller/tainteviction/taint_eviction.go
pod := obj.(*v1.Pod) tm.PodUpdated(nil, pod) }, UpdateFunc: func(prev, obj interface{}) { prevPod := prev.(*v1.Pod) newPod := obj.(*v1.Pod) tm.PodUpdated(prevPod, newPod) }, DeleteFunc: func(obj interface{}) { pod, isPod := obj.(*v1.Pod) // We can get DeletedFinalStateUnknown instead of *v1.Pod here and we need to handle that correctly. if !isPod {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 19.9K bytes - Viewed (0) -
pkg/controller/bootstrap/bootstrapsigner.go
return false } }, Handler: cache.ResourceEventHandlerFuncs{ AddFunc: func(_ interface{}) { e.pokeConfigMapSync() }, UpdateFunc: func(_, _ interface{}) { e.pokeConfigMapSync() }, DeleteFunc: func(_ interface{}) { e.pokeConfigMapSync() }, }, }, options.SecretResync, ) return e, nil } // Run runs controller loops and returns when they are done
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/kubelet/clustertrustbundle/clustertrustbundle_manager.go
if !ok { return } klog.InfoS("Dropping cache for ClusterTrustBundle", "signerName", ctb.Spec.SignerName) m.dropCacheFor(new.(*certificatesv1alpha1.ClusterTrustBundle)) }, DeleteFunc: func(obj any) { ctb, ok := obj.(*certificatesv1alpha1.ClusterTrustBundle) if !ok { tombstone, ok := obj.(cache.DeletedFinalStateUnknown) if !ok { return }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Nov 03 18:40:48 UTC 2023 - 8.3K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/controller/nonstructuralschema/nonstructuralschema_controller.go
lastSeenGeneration: map[string]int64{}, } crdInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{ AddFunc: c.addCustomResourceDefinition, UpdateFunc: c.updateCustomResourceDefinition, DeleteFunc: c.deleteCustomResourceDefinition, }) c.syncFn = c.sync return c } func calculateCondition(in *apiextensionsv1.CustomResourceDefinition) *apiextensionsv1.CustomResourceDefinitionCondition {
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/apiextensions-apiserver/pkg/controller/openapiv3/controller.go
} 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 - 7.9K bytes - Viewed (0) -
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) -
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) -
pkg/kube/namespace/filter.go
added := sets.New(new.Name) var removed sets.String if !namespaceAdded { removed = added added = nil } f.notifyHandlersLocked(added, removed) } }, DeleteFunc: func(ns *corev1.Namespace) { f.lock.Lock() defer f.lock.Unlock() // No need to notify handlers for deletes. The namespace was deleted, so the object will be as well (and a delete could not de-select).
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jun 10 17:12:52 UTC 2024 - 9.3K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/policy/internal/generic/controller.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 7.5K bytes - Viewed (0)