storage

Documentation

Index

• func NewStorage(nano v1.Nanokube) v1.Storage
• type StorageClientImpl
  • 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, ...) error
  • func (sc *StorageClientImpl) EnableResourceSizeEstimation(fn storage.KeysFunc) error
  • func (sc *StorageClientImpl) Get(ctx context.Context, key string, opts storage.GetOptions, ...) error
  • func (sc *StorageClientImpl) GetCurrentResourceVersion(ctx context.Context) (uint64, error)
  • func (sc *StorageClientImpl) GetList(ctx context.Context, key string, opts storage.ListOptions, ...) error
  • func (sc *StorageClientImpl) GuaranteedUpdate(ctx context.Context, key string, destination 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)
• type StorageImpl
  • 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

Functions

func NewStorage

func NewStorage(nano v1.Nanokube) v1.Storage

Types

type StorageClientImpl

type StorageClientImpl struct {
	// contains filtered or unexported fields
}

func (*StorageClientImpl) CompactRevision

func (sc *StorageClientImpl) CompactRevision() int64

func (*StorageClientImpl) Create

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

func (*StorageClientImpl) Delete

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 (*StorageClientImpl) EnableResourceSizeEstimation

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

func (*StorageClientImpl) Get

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

func (*StorageClientImpl) GetCurrentResourceVersion

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

func (*StorageClientImpl) GetList

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

func (*StorageClientImpl) GuaranteedUpdate

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 (*StorageClientImpl) ReadinessCheck

func (sc *StorageClientImpl) ReadinessCheck() error

func (*StorageClientImpl) RequestWatchProgress

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

func (*StorageClientImpl) Stats

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

func (*StorageClientImpl) Versioner

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

func (*StorageClientImpl) Watch

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

type StorageImpl

type StorageImpl struct {
	// contains filtered or unexported fields
}

func (*StorageImpl) GetRESTOptions

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

func (*StorageImpl) Servers

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

func (*StorageImpl) SetConfig

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

func (*StorageImpl) Shutdown

func (s *StorageImpl) Shutdown()

func (*StorageImpl) WithResource

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