- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 79 for DeleteFunc (0.81 sec)
-
staging/src/k8s.io/apiserver/pkg/admission/configuration/mutating_webhook_manager.go
UpdateFunc: func(old, new interface{}) { obj := new.(*v1.MutatingWebhookConfiguration) manager.configurationsCache.Delete(obj.GetName()) manager.lazy.Notify() }, DeleteFunc: func(obj interface{}) { vwc, ok := obj.(*v1.MutatingWebhookConfiguration) if !ok { tombstone, ok := obj.(cache.DeletedFinalStateUnknown) if !ok {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jul 13 22:43:12 UTC 2023 - 5.9K bytes - Viewed (0) -
pkg/controller/certificates/certificate_controller.go
UpdateFunc: func(old, new interface{}) { oldCSR := old.(*certificates.CertificateSigningRequest) logger.V(4).Info("Updating certificate request", "old", oldCSR.Name) cc.enqueueCertificateRequest(new) }, DeleteFunc: func(obj interface{}) { csr, ok := obj.(*certificates.CertificateSigningRequest) if !ok { tombstone, ok := obj.(cache.DeletedFinalStateUnknown) if !ok {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 6.4K bytes - Viewed (0) -
pkg/controller/deployment/deployment_controller.go
DeleteFunc: func(obj interface{}) { dc.deleteDeployment(logger, obj) }, }) rsInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{ AddFunc: func(obj interface{}) { dc.addReplicaSet(logger, obj) }, UpdateFunc: func(oldObj, newObj interface{}) { dc.updateReplicaSet(logger, oldObj, newObj) }, DeleteFunc: func(obj interface{}) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 24.2K bytes - Viewed (0) -
pkg/controller/certificates/rootcacertpublisher/publisher.go
workqueue.TypedRateLimitingQueueConfig[string]{ Name: "root_ca_cert_publisher", }, ), } cmInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{ DeleteFunc: e.configMapDeleted, UpdateFunc: e.configMapUpdated, }) e.cmLister = cmInformer.Lister() e.cmListerSynced = cmInformer.Informer().HasSynced nsInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 6.8K bytes - Viewed (0) -
pkg/kube/krt/informer.go
}, initialSync) }, UpdateFunc: func(oldObj, newObj I) { handler(Event[I]{ Old: &oldObj, New: &newObj, Event: controllers.EventUpdate, }, false) }, DeleteFunc: func(obj I) { handler(Event[I]{ Old: &obj, Event: controllers.EventDelete, }, false) }, } } // WrapClient is the base entrypoint that enables the creation
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jun 10 11:01:46 UTC 2024 - 6.1K bytes - Viewed (0) -
pkg/controller/clusterroleaggregation/clusterroleaggregation_controller.go
clusterRoleInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{ AddFunc: func(obj interface{}) { c.enqueue() }, UpdateFunc: func(old, cur interface{}) { c.enqueue() }, DeleteFunc: func(uncast interface{}) { c.enqueue() }, }) return c } func (c *ClusterRoleAggregationController) syncClusterRole(ctx context.Context, key string) error {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 8K bytes - Viewed (0) -
pkg/controller/servicecidrs/servicecidrs_controller.go
AddFunc: c.addServiceCIDR, UpdateFunc: c.updateServiceCIDR, DeleteFunc: c.deleteServiceCIDR, }) c.serviceCIDRLister = serviceCIDRInformer.Lister() c.serviceCIDRsSynced = serviceCIDRInformer.Informer().HasSynced _, _ = ipAddressInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{ AddFunc: c.addIPAddress, DeleteFunc: c.deleteIPAddress, }) c.ipAddressLister = ipAddressInformer.Lister()
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/serviceaccount/serviceaccounts_controller.go
workqueue.TypedRateLimitingQueueConfig[string]{Name: "serviceaccount"}, ), } saHandler, _ := saInformer.Informer().AddEventHandlerWithResyncPeriod(cache.ResourceEventHandlerFuncs{ DeleteFunc: e.serviceAccountDeleted, }, options.ServiceAccountResync) e.saLister = saInformer.Lister() e.saListerSynced = saHandler.HasSynced
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 7.5K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/controller/apiapproval/apiapproval_controller.go
} crdInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{ AddFunc: c.addCustomResourceDefinition, UpdateFunc: c.updateCustomResourceDefinition, DeleteFunc: c.deleteCustomResourceDefinition, }) c.syncFn = c.sync return c } // calculateCondition determines the new KubernetesAPIApprovalPolicyConformant condition
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/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)