datastore

Documentation

Index

• type KVStore
  • func NewKVStore(path string, options *KVStoreOptions) (*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
• type KVStoreOptions

Types

type KVStore

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

KVStore is the key value datastore

func NewKVStore

func NewKVStore(path string, options *KVStoreOptions) (*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

type KVStoreOptions

type KVStoreOptions struct {
	EnableTruncate                              *wrappers.BoolValue
	MaxTableSize                                *wrappers.Int64Value
	LevelOneSize                                *wrappers.Int64Value
	LevelSizeMultiplier                         *wrappers.Int32Value
	NumberOfLevelZeroTables                     *wrappers.Int32Value
	NumberOfLevelZeroTablesUntilForceCompaction *wrappers.Int32Value
	GarbageCollectionDiscardRatio               *wrappers.FloatValue
}

KVStoreOptions represent environment variable configurable options related to the KV Store.