Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 20 for GuaranteedUpdate (0.22 sec)

  1. pkg/registry/core/namespace/storage/storage.go

    			return nil, false, err
    		}
    
    		preconditions := storage.Preconditions{UID: options.Preconditions.UID, ResourceVersion: options.Preconditions.ResourceVersion}
    
    		out := r.store.NewFunc()
    		err = r.store.Storage.GuaranteedUpdate(
    			ctx, key, out, false, &preconditions,
    			storage.SimpleUpdate(func(existing runtime.Object) (runtime.Object, error) {
    				existingNamespace, ok := existing.(*api.Namespace)
    				if !ok {
    					// wrong type
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Nov 18 09:21:19 UTC 2022
    - 13.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/endpoints/handlers/patch.go

    		return err
    	}
    	return nil
    }
    
    // applyPatch is called every time GuaranteedUpdate asks for the updated object,
    // and is given the currently persisted object as input.
    // TODO: rename this function because the name implies it is related to applyPatcher
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 28 08:48:22 UTC 2024
    - 28.5K bytes
    - Viewed (0)
  4. 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)
  5. pkg/registry/core/pod/storage/storage.go

    		if podUID != "" {
    			preconditions.UID = &podUID
    		}
    		if podResourceVersion != "" {
    			preconditions.ResourceVersion = &podResourceVersion
    		}
    	}
    
    	err = r.store.Storage.GuaranteedUpdate(ctx, podKey, &api.Pod{}, false, preconditions, storage.SimpleUpdate(func(obj runtime.Object) (runtime.Object, error) {
    		pod, ok := obj.(*api.Pod)
    		if !ok {
    			return nil, fmt.Errorf("unexpected object: %#v", obj)
    		}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Mar 20 14:29:25 UTC 2023
    - 13.7K bytes
    - Viewed (0)
  6. staging/src/k8s.io/apiserver/pkg/endpoints/handlers/rest_test.go

    	// Simulate GuaranteedUpdate behavior (retries internally on etcd changes if the incoming resource doesn't pin resourceVersion)
    	for {
    		currentPod := p.startingPod
    		if p.numUpdates > 0 {
    			currentPod = p.updatePod
    		}
    		p.numUpdates++
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 28 08:48:22 UTC 2024
    - 41.8K bytes
    - Viewed (0)
  7. pkg/registry/apps/deployment/storage/storage.go

    	dKey, err := r.store.KeyFunc(ctx, deploymentID)
    	if err != nil {
    		return nil, err
    	}
    	var finalDeployment *apps.Deployment
    	err = r.store.Storage.GuaranteedUpdate(ctx, dKey, &apps.Deployment{}, false, nil, storage.SimpleUpdate(func(obj runtime.Object) (runtime.Object, error) {
    		d, ok := obj.(*apps.Deployment)
    		if !ok {
    			return nil, fmt.Errorf("unexpected object: %#v", obj)
    		}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Mar 08 21:44:00 UTC 2023
    - 16.8K bytes
    - Viewed (0)
  8. 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)
  9. 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)
  10. 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