Search Options

Results per page
Sort
Preferred Languages
Advance

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

  1. 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)
  2. staging/src/k8s.io/apiserver/pkg/storage/etcd3/store_test.go

    	expectInvalidKey("Get", store.Get(ctx, invalidKey, storage.GetOptions{}, nil))
    	expectInvalidKey("GetList", store.GetList(ctx, invalidKey, storage.ListOptions{}, nil))
    	expectInvalidKey("GuaranteedUpdate", store.GuaranteedUpdate(ctx, invalidKey, nil, true, nil, nil, nil))
    	_, countErr := store.Count(invalidKey)
    	expectInvalidKey("Count", countErr)
    }
    
    func TestResolveGetListRev(t *testing.T) {
    	_, store, _ := testSetup(t)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 11 12:45:33 UTC 2024
    - 26.5K 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_test.go

    	cachedObj runtime.Object
    }
    
    // GuaranteedUpdate overwrites the method with one that always suggests the cachedObj.
    func (s *staleGuaranteedUpdateStorage) 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
    - 101.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