Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for GuaranteedUpdate (0.19 sec)

  1. staging/src/k8s.io/apiserver/pkg/storage/testing/watcher_tests.go

    			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 {
    				t.Fatalf("GuaranteedUpdate of bad pod failed: %v", err)
    			}
    
    			var prevObj *example.Pod
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 63.8K bytes
    - Viewed (0)
  2. staging/src/k8s.io/apiserver/pkg/storage/testing/store_tests.go

    		return input, nil, nil
    	}
    	// GuaranteedUpdate without suggestion should return an error
    	if err := store.GuaranteedUpdate(ctx, preset[1].key, &example.Pod{}, false, nil, updateFunc, nil); !storage.IsInternalError(err) {
    		t.Errorf("Unexpected error: %v", err)
    	}
    	// GuaranteedUpdate with suggestion should return an error if we don't change the object
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 11 12:45:33 UTC 2024
    - 91.4K bytes
    - Viewed (0)
  3. staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher.go

    			return err
    		}
    	}
    	metrics.RecordListCacheMetrics(c.resourcePrefix, indexUsed, len(objs), listVal.Len())
    	return nil
    }
    
    // GuaranteedUpdate implements storage.Interface.
    func (c *Cacher) GuaranteedUpdate(
    	ctx context.Context, key string, destination runtime.Object, ignoreNotFound bool,
    	preconditions *storage.Preconditions, tryUpdate storage.UpdateFunc, _ runtime.Object) error {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 10:12:02 UTC 2024
    - 51.8K bytes
    - Viewed (0)
  4. staging/src/k8s.io/apiserver/pkg/registry/generic/registry/store.go

    		storagePreconditions.ResourceVersion = preconditions.ResourceVersion
    	}
    
    	out := e.NewFunc()
    	// deleteObj is only used in case a deletion is carried out
    	var deleteObj runtime.Object
    	err = e.Storage.GuaranteedUpdate(ctx, key, out, true, storagePreconditions, func(existing runtime.Object, res storage.ResponseMeta) (runtime.Object, *uint64, error) {
    		existingResourceVersion, err := e.Storage.Versioner().ObjectResourceVersion(existing)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jan 19 23:22:44 UTC 2024
    - 60.8K bytes
    - Viewed (0)
  5. staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher_whitebox_test.go

    	}
    	d.RLock()
    	defer d.RUnlock()
    	podList := listObj.(*example.PodList)
    	podList.ListMeta = metav1.ListMeta{ResourceVersion: "100"}
    	return d.err
    }
    func (d *dummyStorage) GuaranteedUpdate(_ context.Context, _ string, _ runtime.Object, _ bool, _ *storage.Preconditions, _ storage.UpdateFunc, _ runtime.Object) error {
    	return fmt.Errorf("unimplemented")
    }
    func (d *dummyStorage) Count(_ string) (int64, error) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 10:12:02 UTC 2024
    - 82.9K bytes
    - Viewed (0)
Back to top