kvstore

Documentation

Index

• Constants
• Variables
• type KvStore
  • func New(logger log.Logger, dir string, blobStore store.BlobStore, ...) (*KvStore, error)
  • func (kv *KvStore) Close() error
  • func (kv *KvStore) Get(ctx context.Context, key string, version int64) (*vkv.KeyValue, error)
  • func (kv *KvStore) GetMetaBlob(ctx context.Context, key string, version int64) (string, error)
  • func (kv *KvStore) Keys(ctx context.Context, start, end string, limit int) ([]*vkv.KeyValue, string, error)
  • func (kv *KvStore) Put(ctx context.Context, key, ref string, data []byte, version int64) (*vkv.KeyValue, error)
  • func (kv *KvStore) ReverseKeys(ctx context.Context, start, end string, limit int) ([]*vkv.KeyValue, string, error)
  • func (kv *KvStore) Versions(ctx context.Context, key, start string, limit int) (*vkv.KeyValueVersions, string, error)

Constants

const KvType = "kv"

Variables

var ErrInvalidKey = errors.New("/ is a forbidden character for keys")

Types

type KvStore

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

func New

func New(logger log.Logger, dir string, blobStore store.BlobStore, metaHandler *meta.Meta) (*KvStore, error)

func (*KvStore) Close

func (kv *KvStore) Close() error

func (*KvStore) Get

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

func (*KvStore) GetMetaBlob

func (kv *KvStore) GetMetaBlob(ctx context.Context, key string, version int64) (string, error)

func (*KvStore) Keys

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

func (*KvStore) Put

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

func (*KvStore) ReverseKeys

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

func (*KvStore) Versions

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