- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 94 for UpdateFunc (0.28 sec)
-
pkg/controller/certificates/certificate_controller.go
AddFunc: func(obj interface{}) { csr := obj.(*certificates.CertificateSigningRequest) logger.V(4).Info("Adding certificate request", "csr", csr.Name) cc.enqueueCertificateRequest(obj) }, UpdateFunc: func(old, new interface{}) { oldCSR := old.(*certificates.CertificateSigningRequest) logger.V(4).Info("Updating certificate request", "old", oldCSR.Name) cc.enqueueCertificateRequest(new) },
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/registry/core/replicationcontroller/storage/storage_test.go
test.TestUpdate( // valid validNewController(), // valid updateFunc func(obj runtime.Object) runtime.Object { object := obj.(*api.ReplicationController) object.Spec.Replicas = object.Spec.Replicas + 1 return object }, // invalid updateFunc func(obj runtime.Object) runtime.Object { object := obj.(*api.ReplicationController) object.Name = ""
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Apr 16 06:57:01 UTC 2024 - 16.9K bytes - Viewed (0) -
pkg/controller/volume/pvcprotection/pvc_protection_controller.go
e.pvcListerSynced = pvcInformer.Informer().HasSynced pvcInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{ AddFunc: func(obj interface{}) { e.pvcAddedUpdated(logger, obj) }, UpdateFunc: func(old, new interface{}) { e.pvcAddedUpdated(logger, new) }, }) e.podLister = podInformer.Lister() e.podListerSynced = podInformer.Informer().HasSynced e.podIndexer = podInformer.Informer().GetIndexer()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 14K bytes - Viewed (0) -
pkg/controller/volume/pvprotection/pv_protection_controller.go
e.pvListerSynced = pvInformer.Informer().HasSynced pvInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{ AddFunc: func(obj interface{}) { e.pvAddedUpdated(logger, obj) }, UpdateFunc: func(old, new interface{}) { e.pvAddedUpdated(logger, new) }, }) return e } // Run runs the controller goroutines. func (c *Controller) Run(ctx context.Context, workers int) {
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/registry/core/serviceaccount/storage/storage_test.go
defer server.Terminate(t) defer storage.Store.DestroyFunc() test := genericregistrytest.New(t, storage.Store) test.TestUpdate( // valid validNewServiceAccount("foo"), // updateFunc func(obj runtime.Object) runtime.Object { object := obj.(*api.ServiceAccount) object.Secrets = []api.ObjectReference{{}} return object }, ) } func TestDelete(t *testing.T) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 6.7K bytes - Viewed (0) -
pkg/controller/clusterroleaggregation/clusterroleaggregation_controller.go
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/serviceaccount/serviceaccounts_controller.go
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/kube/krt/informer.go
return controllers.EventHandler[I]{ AddExtendedFunc: func(obj I, initialSync bool) { handler(Event[I]{ New: &obj, Event: controllers.EventAdd, }, initialSync) }, UpdateFunc: func(oldObj, newObj I) { handler(Event[I]{ Old: &oldObj, New: &newObj, Event: controllers.EventUpdate, }, false) }, DeleteFunc: func(obj I) { handler(Event[I]{
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/bootstrap/tokencleaner.go
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 } // 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 - 6.3K bytes - Viewed (0)