datastore

Documentation

Index

• type KVStore
  • func NewKVStore(path string) (*KVStore, error)
  • func (s *KVStore) GarbageCollect() error
  • func (s *KVStore) Get(request *apiv1.GetValuesRequest) (*apiv1.GetValuesResponse, error)
  • func (s *KVStore) Set(request *apiv1.SetValuesRequest) error
  • func (s *KVStore) Subscribe(ctx context.Context, subscription *apiv1.SubscribeRequest, ...) error

Types

type KVStore

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

KVStore is the key value datastore

func NewKVStore

func NewKVStore(path string) (*KVStore, error)

NewKVStore creates a new key value datastore

func (*KVStore) GarbageCollect

func (s *KVStore) GarbageCollect() error

GarbageCollect cleans up old values in log files

func (*KVStore) Get

func (s *KVStore) Get(request *apiv1.GetValuesRequest) (*apiv1.GetValuesResponse, error)

Get retrieves key values from the datastore.

func (*KVStore) Set

func (s *KVStore) Set(request *apiv1.SetValuesRequest) error

Set sets key values in the datastore.

func (*KVStore) Subscribe

func (s *KVStore) Subscribe(ctx context.Context, subscription *apiv1.SubscribeRequest, cb func(*apiv1.SubscribeResponse) error) error

Subscribe will subscribe to prefixes in the key value store. This will block until there is an error or the context is cancelled