Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for tryUpdate (0.85 sec)

  1. staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher.go

    		return c.storage.GuaranteedUpdate(ctx, key, destination, ignoreNotFound, preconditions, tryUpdate, currObj)
    	}
    	// If we couldn't get the object, fallback to no-suggestion.
    	return c.storage.GuaranteedUpdate(ctx, key, destination, ignoreNotFound, preconditions, tryUpdate, nil)
    }
    
    // Count implements storage.Interface.
    func (c *Cacher) Count(pathPrefix string) (int64, 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)
  2. staging/src/k8s.io/apiserver/pkg/registry/generic/registry/store_test.go

    	ctx context.Context, key string, destination runtime.Object, ignoreNotFound bool,
    	preconditions *storage.Preconditions, tryUpdate storage.UpdateFunc, _ runtime.Object) error {
    	return s.Interface.GuaranteedUpdate(ctx, key, destination, ignoreNotFound, preconditions, tryUpdate, s.cachedObj)
    }
    
    func TestDeleteWithCachedObject(t *testing.T) {
    	podName := "foo"
    	podWithFinalizer := &example.Pod{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 10:12:02 UTC 2024
    - 101.8K bytes
    - Viewed (0)
Back to top