- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for SimpleUpdate (0.12 sec)
-
staging/src/k8s.io/apiserver/pkg/storage/testing/store_tests.go
// passed originalPod, and make sure that SimpleUpdate is called a second time after a live lookup // with the value of updatedPod. sawConflict := false updatedPod2 := &example.Pod{} err = store.GuaranteedUpdate(ctx, key, updatedPod2, false, nil, storage.SimpleUpdate(func(obj runtime.Object) (runtime.Object, error) { pod := obj.(*example.Pod)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 11 12:45:33 UTC 2024 - 91.4K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/testing/watcher_tests.go
// that its corresponding event will not be propagated. badKey := fmt.Sprintf("/pods/%s-bad/foo", tt.namespace) badOut := &example.Pod{} err = store.GuaranteedUpdate(ctx, badKey, badOut, true, nil, storage.SimpleUpdate( func(runtime.Object) (runtime.Object, error) { obj := basePod.DeepCopy() obj.Namespace = fmt.Sprintf("%s-bad", tt.namespace) return obj, nil }), nil) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 63.8K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/registry/generic/registry/store.go
lastGraceful := int64(0) var pendingFinalizers bool out = e.NewFunc() err = e.Storage.GuaranteedUpdate( ctx, key, out, false, /* ignoreNotFound */ &preconditions, storage.SimpleUpdate(func(existing runtime.Object) (runtime.Object, error) { if err := deleteValidation(ctx, existing); err != nil { return nil, err }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jan 19 23:22:44 UTC 2024 - 60.8K bytes - Viewed (0)