store

Documentation

Index

• type BlobStore
• type BlobStoreProxy
  • func (p *BlobStoreProxy) Enumerate(ctx context.Context, start, end string, limit int) ([]*blob.SizedBlobRef, string, error)
  • func (p *BlobStoreProxy) Get(ctx context.Context, hash string) ([]byte, error)
  • func (p *BlobStoreProxy) Put(ctx context.Context, blob *blob.Blob) (bool, error)
  • func (p *BlobStoreProxy) Stat(ctx context.Context, hash string) (bool, error)
• type DataContext
• type KvStore
• type KvStoreProxy
  • func (p *KvStoreProxy) Get(ctx context.Context, key string, version int64) (*vkv.KeyValue, error)
  • func (p *KvStoreProxy) GetMetaBlob(ctx context.Context, key string, version int64) (string, error)
  • func (p *KvStoreProxy) Keys(ctx context.Context, start, end string, limit int) ([]*vkv.KeyValue, string, error)
  • func (p *KvStoreProxy) Put(ctx context.Context, key, ref string, data []byte, version int64) (*vkv.KeyValue, error)
  • func (p *KvStoreProxy) ReverseKeys(ctx context.Context, start, end string, limit int) ([]*vkv.KeyValue, string, error)
  • func (p *KvStoreProxy) Versions(ctx context.Context, key, start string, limit int) (*vkv.KeyValueVersions, string, error)

Types

type BlobStore

type BlobStore interface {
	Put(ctx context.Context, blob *blob.Blob) (bool, error)
	Get(ctx context.Context, hash string) ([]byte, error)
	Stat(ctx context.Context, hash string) (bool, error)
	Enumerate(ctx context.Context, start, end string, limit int) ([]*blob.SizedBlobRef, string, error)
	Close() error
}

type BlobStoreProxy

type BlobStoreProxy struct {
	BlobStore
	ReadSrc BlobStore
}

func (*BlobStoreProxy) Enumerate

func (p *BlobStoreProxy) Enumerate(ctx context.Context, start, end string, limit int) ([]*blob.SizedBlobRef, string, error)

func (*BlobStoreProxy) Get

func (p *BlobStoreProxy) Get(ctx context.Context, hash string) ([]byte, error)

func (*BlobStoreProxy) Put

func (p *BlobStoreProxy) Put(ctx context.Context, blob *blob.Blob) (bool, error)

func (*BlobStoreProxy) Stat

func (p *BlobStoreProxy) Stat(ctx context.Context, hash string) (bool, error)

type DataContext

type DataContext interface {
	StashBlobStore() BlobStore
	BlobStore() BlobStore
	KvStore() KvStore
	BlobStoreProxy() BlobStore
	KvStoreProxy() KvStore
	Merge(context.Context) error
	Close() error
	Closed() bool
	Destroy() error
}

type KvStore

type KvStore interface {
	Put(ctx context.Context, key, ref string, data []byte, version int64) (*vkv.KeyValue, error)
	Get(ctx context.Context, key string, version int64) (*vkv.KeyValue, error)
	GetMetaBlob(ctx context.Context, key string, version int64) (string, error)
	Versions(ctx context.Context, key, start string, limit int) (*vkv.KeyValueVersions, string, error)
	Keys(ctx context.Context, start, end string, limit int) ([]*vkv.KeyValue, string, error)
	ReverseKeys(ctx context.Context, start, end string, limit int) ([]*vkv.KeyValue, string, error)
	Close() error
}

type KvStoreProxy

type KvStoreProxy struct {
	KvStore
	ReadSrc KvStore
}

func (*KvStoreProxy) Get

func (p *KvStoreProxy) Get(ctx context.Context, key string, version int64) (*vkv.KeyValue, error)

func (*KvStoreProxy) GetMetaBlob

func (p *KvStoreProxy) GetMetaBlob(ctx context.Context, key string, version int64) (string, error)

func (*KvStoreProxy) Keys

func (p *KvStoreProxy) Keys(ctx context.Context, start, end string, limit int) ([]*vkv.KeyValue, string, error)

func (*KvStoreProxy) Put

func (p *KvStoreProxy) Put(ctx context.Context, key, ref string, data []byte, version int64) (*vkv.KeyValue, error)

func (*KvStoreProxy) ReverseKeys

func (p *KvStoreProxy) ReverseKeys(ctx context.Context, start, end string, limit int) ([]*vkv.KeyValue, string, error)

func (*KvStoreProxy) Versions

func (p *KvStoreProxy) Versions(ctx context.Context, key, start string, limit int) (*vkv.KeyValueVersions, string, error)