Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for SimpleUpdate (0.12 sec)

  1. 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)
  2. 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)
  3. 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)
Back to top