- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 47 for add_func (0.12 sec)
-
pkg/controller/bootstrap/tokencleaner.go
default: utilruntime.HandleError(fmt.Errorf("object passed to %T that is not expected: %T", e, obj)) return false } }, Handler: cache.ResourceEventHandlerFuncs{ AddFunc: e.enqueueSecrets, UpdateFunc: func(oldSecret, newSecret interface{}) { e.enqueueSecrets(newSecret) }, }, }, options.SecretResync, ) return e, nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 6.3K bytes - Viewed (0) -
pkg/controller/serviceaccount/serviceaccounts_controller.go
}, options.ServiceAccountResync) e.saLister = saInformer.Lister() e.saListerSynced = saHandler.HasSynced nsHandler, _ := nsInformer.Informer().AddEventHandlerWithResyncPeriod(cache.ResourceEventHandlerFuncs{ AddFunc: e.namespaceAdded, UpdateFunc: e.namespaceUpdated, }, options.NamespaceResync) e.nsLister = nsInformer.Lister() e.nsListerSynced = nsHandler.HasSynced e.syncHandler = e.syncNamespace return e, nil
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
), lastSeenProtectedAnnotation: map[string]string{}, } crdInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{ AddFunc: c.addCustomResourceDefinition, UpdateFunc: c.updateCustomResourceDefinition, DeleteFunc: c.deleteCustomResourceDefinition, }) c.syncFn = c.sync return c }
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/storageversionmigrator/resourceversion.go
workqueue.TypedRateLimitingQueueConfig[string]{Name: ResourceVersionControllerName}, ), } _, _ = svmInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{ AddFunc: func(obj interface{}) { rvController.addSVM(logger, obj) }, UpdateFunc: func(oldObj, newObj interface{}) { rvController.updateSVM(logger, oldObj, newObj) }, }) return rvController }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 8.5K bytes - Viewed (0) -
pkg/kubelet/clustertrustbundle/clustertrustbundle_manager.go
cacheTTL: cacheTTL, } // Have the informer bust cache entries when it sees updates that could // apply to them. _, err := m.ctbInformer.AddEventHandler(cache.ResourceEventHandlerFuncs{ AddFunc: func(obj any) { ctb, ok := obj.(*certificatesv1alpha1.ClusterTrustBundle) if !ok { return } klog.InfoS("Dropping all cache entries for signer", "signerName", ctb.Spec.SignerName) m.dropCacheFor(ctb)
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 }
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
), specsByGVandName: map[schema.GroupVersion]map[string]*spec3.OpenAPI{}, } crdInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{ AddFunc: c.addCustomResourceDefinition, UpdateFunc: c.updateCustomResourceDefinition, DeleteFunc: c.deleteCustomResourceDefinition, }) c.syncFn = c.sync return c }
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/namespace/namespace_controller.go
} // configure the namespace informer event handlers namespaceInformer.Informer().AddEventHandlerWithResyncPeriod( cache.ResourceEventHandlerFuncs{ AddFunc: func(obj interface{}) { namespace := obj.(*v1.Namespace) namespaceController.enqueueNamespace(namespace) }, UpdateFunc: func(oldObj, newObj interface{}) { namespace := newObj.(*v1.Namespace)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 7.6K bytes - Viewed (0) -
pkg/kube/namespace/filter.go
} mesh.AddMeshHandler(func() { f.selectorsChanged(mesh.Mesh().GetDiscoverySelectors(), true) }) namespaces.AddEventHandler(controllers.EventHandler[*corev1.Namespace]{ AddFunc: func(ns *corev1.Namespace) { f.lock.Lock() defer f.lock.Unlock() // In rare cases, a namespace may be created after objects in the namespace, because there is no synchronization between watches
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jun 10 17:12:52 UTC 2024 - 9.3K bytes - Viewed (0) -
pkg/controller/storageversionmigrator/storageversionmigrator.go
workqueue.DefaultTypedControllerRateLimiter[string](), workqueue.TypedRateLimitingQueueConfig[string]{Name: controllerName}, ), } _, _ = svmInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{ AddFunc: func(obj interface{}) { svmController.addSVM(logger, obj) }, UpdateFunc: func(oldObj, newObj interface{}) { svmController.updateSVM(logger, oldObj, newObj) }, }) return svmController }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 9.5K bytes - Viewed (0)