- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 131 for UpdateFunc (0.25 sec)
-
pkg/registry/storage/storageclass/storage/storage_test.go
defer server.Terminate(t) defer storage.Store.DestroyFunc() test := genericregistrytest.New(t, storage.Store).ClusterScope() test.TestUpdate( // valid validNewStorageClass("foo"), // updateFunc func(obj runtime.Object) runtime.Object { object := obj.(*storageapi.StorageClass) object.Parameters = map[string]string{"foo": "bar"} return object }, //invalid update
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Aug 12 20:55:35 UTC 2019 - 4.6K bytes - Viewed (0) -
pkg/controller/endpointslice/endpointslice_controller.go
AddFunc: c.onServiceUpdate, UpdateFunc: func(old, cur interface{}) { c.onServiceUpdate(cur) }, DeleteFunc: c.onServiceDelete, }) c.serviceLister = serviceInformer.Lister() c.servicesSynced = serviceInformer.Informer().HasSynced podInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{ AddFunc: c.addPod, UpdateFunc: c.updatePod, DeleteFunc: c.deletePod, })
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 08:33:32 UTC 2024 - 23.6K bytes - Viewed (0) -
pkg/registry/resource/resourceclaimparameters/storage/storage_test.go
defer server.Terminate(t) defer storage.Store.DestroyFunc() test := genericregistrytest.New(t, storage.Store) test.TestUpdate( // valid validNewResourceClaimParameters("foo"), // updateFunc func(obj runtime.Object) runtime.Object { object := obj.(*resource.ResourceClaimParameters) object.Labels = map[string]string{"foo": "bar"} return object }, // invalid update
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 15:15:31 UTC 2024 - 4K bytes - Viewed (0) -
pkg/registry/resource/resourceslice/storage/storage_test.go
defer server.Terminate(t) defer storage.Store.DestroyFunc() test := genericregistrytest.New(t, storage.Store).ClusterScope() test.TestUpdate( // valid validNewResourceSlice("foo"), // updateFunc func(obj runtime.Object) runtime.Object { object := obj.(*resource.ResourceSlice) object.Labels = map[string]string{"foo": "bar"} return object }, // invalid update
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 14 17:07:36 UTC 2024 - 4.1K bytes - Viewed (0) -
pkg/kube/kclient/clienttest/test_helpers.go
return controllers.EventHandler[controllers.Object]{ AddFunc: func(obj controllers.Object) { tracker.Record("add/" + obj.GetName()) }, UpdateFunc: func(oldObj, newObj controllers.Object) { tracker.Record("update/" + newObj.GetName()) }, DeleteFunc: func(obj controllers.Object) { tracker.Record("delete/" + obj.GetName()) }, } }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Feb 23 19:18:21 UTC 2024 - 3.9K bytes - Viewed (0) -
pkg/registry/resource/podschedulingcontext/storage/storage_test.go
defer server.Terminate(t) defer storage.Store.DestroyFunc() test := genericregistrytest.New(t, storage.Store) test.TestUpdate( // valid validNewPodSchedulingContexts("foo", metav1.NamespaceDefault), // updateFunc func(obj runtime.Object) runtime.Object { object := obj.(*resource.PodSchedulingContext) if object.Labels == nil { object.Labels = map[string]string{} } object.Labels["foo"] = "bar"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 12 15:46:12 UTC 2023 - 5.7K bytes - Viewed (0) -
pkg/registry/storage/csidriver/storage/storage_test.go
defer storage.Store.DestroyFunc() test := genericregistrytest.New(t, storage.Store).ClusterScope() notPodInfoOnMount := false test.TestUpdate( // valid validNewCSIDriver("foo"), // updateFunc func(obj runtime.Object) runtime.Object { object := obj.(*storageapi.CSIDriver) object.Labels = map[string]string{"a": "b"} return object }, //invalid update
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 14 15:49:55 UTC 2023 - 4.7K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/registry/generic/registry/dryrun.go
} func (s *DryRunnableStorage) GuaranteedUpdate( ctx context.Context, key string, destination runtime.Object, ignoreNotFound bool, preconditions *storage.Preconditions, tryUpdate storage.UpdateFunc, dryRun bool, cachedExistingObject runtime.Object) error { if dryRun { var current runtime.Object v, err := conversion.EnforcePtr(destination) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 02 20:40:48 UTC 2023 - 3.8K bytes - Viewed (0) -
pkg/kube/kclient/index.go
AddFunc: func(obj any, initialList bool) { idx.mu.Lock() addObj(obj) idx.mu.Unlock() if delegate != nil { delegate.OnAdd(obj, initialList) } }, UpdateFunc: func(oldObj, newObj any) { idx.mu.Lock() deleteObj(oldObj) addObj(newObj) idx.mu.Unlock() if delegate != nil { delegate.OnUpdate(oldObj, newObj) } }, DeleteFunc: func(obj any) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 04 03:49:30 UTC 2023 - 3.5K bytes - Viewed (0) -
pkg/registry/core/podtemplate/storage/storage_test.go
storage, server := newStorage(t) defer server.Terminate(t) defer storage.Store.DestroyFunc() test := genericregistrytest.New(t, storage.Store) test.TestUpdate( //valid validNewPodTemplate("foo"), // updateFunc func(obj runtime.Object) runtime.Object { object := obj.(*api.PodTemplate) object.Template.Spec.NodeSelector = map[string]string{"a": "b"} return object }, ) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Aug 12 20:55:35 UTC 2019 - 4.1K bytes - Viewed (0)