embeddedkvs

Documentation

Index

• type KVS
  • func New(ctx context.Context, path string) (*KVS, error)
  • func (k *KVS) Close() error
  • func (k *KVS) ForEach(fn func(key string, value []byte) error) error
  • func (k *KVS) GetMulti(ctx context.Context, keys []string, fn func(key string, value []byte) error) error
  • func (k *KVS) Set(key string, value []byte) error
  • func (k *KVS) SetMulti(fn func(set func(key string, value []byte) error) error) error

Types

type KVS

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

func New

func New(ctx context.Context, path string) (*KVS, error)

New instantiates KVS.

func (*KVS) Close

func (k *KVS) Close() error

Close closes KVS.

func (*KVS) ForEach

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

ForEach executes a function for each key/value pair in KVS.

func (*KVS) GetMulti

func (k *KVS) GetMulti(ctx context.Context, keys []string, fn func(key string, value []byte) error) error

GetMulti calls |fn| in parallel for cached entries.

func (*KVS) Set

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

Set sets key/value to storage.

This should be called in parallel for efficient storing.

func (*KVS) SetMulti

func (k *KVS) SetMulti(fn func(set func(key string, value []byte) error) error) error

SetMulti receives callback that takes function which is used to set a key/value pair.