- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 131 for UpdateFunc (0.13 sec)
-
pkg/registry/resource/resourceclass/storage/storage_test.go
defer server.Terminate(t) defer storage.Store.DestroyFunc() test := genericregistrytest.New(t, storage.Store).ClusterScope() test.TestUpdate( // valid validNewClass("foo"), // updateFunc func(obj runtime.Object) runtime.Object { object := obj.(*resource.ResourceClass) object.ParametersRef = &resource.ResourceClassParametersReference{Kind: "cdiexample", Name: "some-name"} return object },
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Nov 10 19:08:24 UTC 2022 - 4K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/interfaces.go
type MatchValue struct { IndexName string Value string } // Pass an UpdateFunc to Interface.GuaranteedUpdate to make an update // that is guaranteed to succeed. // See the comment for GuaranteedUpdate for more details. type UpdateFunc func(input runtime.Object, res ResponseMeta) (output runtime.Object, ttl *uint64, err error)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 29 07:53:48 UTC 2024 - 14.8K bytes - Viewed (0) -
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) -
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/autoscaling/horizontalpodautoscaler/storage/storage_test.go
defer server.Terminate(t) defer storage.Store.DestroyFunc() test := genericregistrytest.New(t, storage.Store) test.TestUpdate( // valid validNewHorizontalPodAutoscaler("foo"), // updateFunc func(obj runtime.Object) runtime.Object { object := obj.(*autoscaling.HorizontalPodAutoscaler) object.Spec.MaxReplicas = object.Spec.MaxReplicas + 1 return object }, ) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 12 15:46:12 UTC 2023 - 6.4K 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/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/registry/resource/resourceclaim/storage/storage_test.go
defer server.Terminate(t) defer storage.Store.DestroyFunc() test := genericregistrytest.New(t, storage.Store) test.TestUpdate( // valid validNewClaim("foo", metav1.NamespaceDefault), // updateFunc func(obj runtime.Object) runtime.Object { object := obj.(*resource.ResourceClaim) if object.Labels == nil { object.Labels = map[string]string{} } object.Labels["foo"] = "bar" return object
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 12 15:46:12 UTC 2023 - 5.4K 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)