- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 100 for UpdateFunc (0.17 sec)
-
pkg/controller/validatingadmissionpolicystatus/controller.go
policyClient: policyClient, typeChecker: typeChecker, } reg, err := policyInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{ AddFunc: func(obj interface{}) { c.enqueuePolicy(obj) }, UpdateFunc: func(oldObj, newObj interface{}) { c.enqueuePolicy(newObj) }, }) if err != nil { return nil, err } c.policySynced = reg.HasSynced return c, nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 5.3K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/configuration/mutating_webhook_manager.go
} manager.lazy.Evaluate = manager.getConfiguration handle, _ := informer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{ AddFunc: func(_ interface{}) { manager.lazy.Notify() }, UpdateFunc: func(old, new interface{}) { obj := new.(*v1.MutatingWebhookConfiguration) manager.configurationsCache.Delete(obj.GetName()) manager.lazy.Notify() }, DeleteFunc: func(obj interface{}) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jul 13 22:43:12 UTC 2023 - 5.9K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/configuration/validating_webhook_manager.go
} manager.lazy.Evaluate = manager.getConfiguration handle, _ := informer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{ AddFunc: func(_ interface{}) { manager.lazy.Notify() }, UpdateFunc: func(old, new interface{}) { obj := new.(*v1.ValidatingWebhookConfiguration) manager.configurationsCache.Delete(obj.GetName()) manager.lazy.Notify() }, DeleteFunc: func(obj interface{}) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jul 13 22:43:12 UTC 2023 - 5.7K bytes - Viewed (0) -
pkg/controller/endpointslicemirroring/endpointslicemirroring_controller.go
), workerLoopPeriod: time.Second, } endpointsInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{ AddFunc: func(obj interface{}) { c.onEndpointsAdd(logger, obj) }, UpdateFunc: func(oldObj, newObj interface{}) { c.onEndpointsUpdate(logger, oldObj, newObj) }, DeleteFunc: func(obj interface{}) { c.onEndpointsDelete(logger, obj) }, })
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 06 23:18:31 UTC 2024 - 20.1K bytes - Viewed (0) -
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/controlplane/controller/legacytokentracking/controller.go
creationRatelimiter: limiter, clock: cl, } informer.AddEventHandler(cache.ResourceEventHandlerFuncs{ AddFunc: func(obj interface{}) { c.enqueue() }, UpdateFunc: func(oldObj, newObj interface{}) { c.enqueue() }, DeleteFunc: func(obj interface{}) { c.enqueue() }, }) return c } func (c *Controller) enqueue() {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 6K 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/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)