Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for GuaranteedUpdate (0.24 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/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)
  3. 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