Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for IgnoreNotFound (0.13 sec)

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

    		key                 string
    		ignoreNotFound      bool
    		precondition        *storage.Preconditions
    		expectNotFoundErr   bool
    		expectInvalidObjErr bool
    		expectNoUpdate      bool
    		transformStale      bool
    		hasSelfLink         bool
    	}{{
    		name:                "non-existing key, ignoreNotFound=false",
    		key:                 "/non-existing",
    		ignoreNotFound:      false,
    		precondition:        nil,
    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/cacher/cacher.go

    		// current object.
    		currObj := elem.(*storeElement).Object.DeepCopyObject()
    		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.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 10:12:02 UTC 2024
    - 51.8K bytes
    - Viewed (0)
  3. staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher_whitebox_test.go

    	err = cacher.Get(context.TODO(), "pods/ns/pod-0", storage.GetOptions{
    		IgnoreNotFound:  true,
    		ResourceVersion: "0",
    	}, result)
    	if err != nil {
    		t.Errorf("Get with RV=0 should be served from cache: %v", err)
    	}
    
    	err = cacher.Get(context.TODO(), "pods/ns/pod-0", storage.GetOptions{
    		IgnoreNotFound:  true,
    		ResourceVersion: "",
    	}, result)
    	if err != errDummy {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 10:12:02 UTC 2024
    - 82.9K bytes
    - Viewed (0)
  4. staging/src/k8s.io/apiserver/pkg/registry/generic/registry/store_test.go

    func (s *staleGuaranteedUpdateStorage) GuaranteedUpdate(
    	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"
    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