storage

Documentation

Index

• type KVS
  • func NewKVS(dir string, valueDir string, logger *zap.Logger) (*KVS, error)
  • func (k *KVS) Close() error
  • func (k *KVS) Delete(key string) error
  • func (k *KVS) Get(key string) ([]byte, error)
  • func (k *KVS) Set(key string, value []byte) error
  • func (k *KVS) SnapshotItems() <-chan *protobuf.KeyValuePair
  • func (k *KVS) Stats() map[string]string

Types

type KVS

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

func NewKVS

func NewKVS(dir string, valueDir string, logger *zap.Logger) (*KVS, error)

func (*KVS) Close

func (k *KVS) Close() error

func (*KVS) Delete

func (k *KVS) Delete(key string) error

func (*KVS) Get

func (k *KVS) Get(key string) ([]byte, error)

func (*KVS) Set

func (k *KVS) Set(key string, value []byte) error

func (*KVS) SnapshotItems

func (k *KVS) SnapshotItems() <-chan *protobuf.KeyValuePair

func (*KVS) Stats

func (k *KVS) Stats() map[string]string