storage

func (sc *StorageClientImpl) CompactRevision() int64

func (sc *StorageClientImpl) Create(ctx context.Context, key string, obj, out runtime.Object, ttl uint64) error

func (sc *StorageClientImpl) Delete(ctx context.Context, key string, out runtime.Object, preconditions *storage.Preconditions, validateDeletion storage.ValidateObjectFunc, cachedExistingObject runtime.Object, opts storage.DeleteOptions) error

func (sc *StorageClientImpl) EnableResourceSizeEstimation(fn storage.KeysFunc) error

func (sc *StorageClientImpl) Get(ctx context.Context, key string, opts storage.GetOptions, objPtr runtime.Object) error

func (sc *StorageClientImpl) GetCurrentResourceVersion(ctx context.Context) (uint64, error)

func (sc *StorageClientImpl) GetList(ctx context.Context, key string, opts storage.ListOptions, listObj runtime.Object) error

func (sc *StorageClientImpl) GuaranteedUpdate(ctx context.Context, key string, destination runtime.Object, ignoreNotFound bool, preconditions *storage.Preconditions, tryUpdate storage.UpdateFunc, cachedExistingObject runtime.Object) error

func (sc *StorageClientImpl) ReadinessCheck() error

func (sc *StorageClientImpl) RequestWatchProgress(ctx context.Context) error

func (sc *StorageClientImpl) Stats(ctx context.Context) (storage.Stats, error)

func (sc *StorageClientImpl) Versioner() storage.Versioner

func (sc *StorageClientImpl) Watch(ctx context.Context, key string, opts storage.ListOptions) (watch.Interface, error)

func (s *StorageImpl) GetRESTOptions(resource schema.GroupResource, example runtime.Object) (generic.RESTOptions, error)

func (s *StorageImpl) Servers() []string

func (s *StorageImpl) SetConfig(config *server.Config) *server.Config

func (s *StorageImpl) Shutdown()

func (s *StorageImpl) WithResource(inner kubestorage.Interface, resource schema.GroupResource) v1.StorageClient