kvs

type KVEntry interface {
	// Key is the key that was retrieved.
	Key() string
	// Value is the retrieved value.
	Value() []byte
	// Operation returns `KVWatchOp`.
	Operation() KVWatchOp
}

type KVStorer interface {
	// GetAllKeys the keys from KV store.
	GetAllKeys(context.Context) ([]string, error)
	// DeleteKey deletes the key from KV store.
	DeleteKey(context.Context, string) error
	// PutKV inserts a key-value pair into the KV store.
	PutKV(context.Context, string, []byte) error
	// GetValue gets the value of the given key.
	GetValue(context.Context, string) ([]byte, error)
	// GetStoreName returns the bucket name of the KV store.
	GetStoreName() string
	// Watch starts watching the KV store for changes. It returns a channel of KVEntry and a done channel.
	// The KVEntry channel is used to read the KVEntry and the done channel is used to indicate the end of the watch.
	Watch(context.Context) (<-chan KVEntry, <-chan struct{})
	// Close closes the backend connection
	Close()
}

type KVWatchOp int64