storewrapper

Documentation

Index

• Constants
• type KVStore
  • func NewKVStore(store types.KVStore, chunkSize int) *KVStore
  • func (k *KVStore) DeleteW(keySrc []byte) (parts int, err error)
  • func (k *KVStore) GetW(keySrc []byte) (res []byte, err error)
  • func (k *KVStore) HasW(keySrc []byte) (parts int, ok bool, err error)
  • func (k *KVStore) SetW(keySrc, valueSrc []byte) (parts int, err error)

Constants

const (
	DefaultChunkSize = 1024 * 5
)

Types

type KVStore

type KVStore struct {
	types.KVStore
	ChunkSize int
}

func NewKVStore

func NewKVStore(store types.KVStore, chunkSize int) *KVStore

Create a wrapper around existing store

func (*KVStore) DeleteW

func (k *KVStore) DeleteW(keySrc []byte) (parts int, err error)

Delete all parts of stored value

func (*KVStore) GetW

func (k *KVStore) GetW(keySrc []byte) (res []byte, err error)

Get all parts of stored value

func (*KVStore) HasW

func (k *KVStore) HasW(keySrc []byte) (parts int, ok bool, err error)

Check if store has value; return number of parts, hasValue, error

func (*KVStore) SetW

func (k *KVStore) SetW(keySrc, valueSrc []byte) (parts int, err error)

Add or update value in store; if update - delete old parts; return parts stored, error