keyvalue

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

type KeyValue interface {
	// Gets a store instance that refers to the store at the specified path.
	Store(string) Store
}

type ScanKeysOption = func(*ScanKeysRequest)

type ScanKeysRequest = v1.KvStoreScanKeysRequest

type Store interface {
	// Name - The name of the store
	Name() string
	// Get a value from the store
	Get(context.Context, string) (map[string]interface{}, error)
	// Set a value in the store
	Set(context.Context, string, map[string]interface{}) error
	// Delete a value from the store
	Delete(context.Context, string) error
	// Return an async iterable of keys in the store
	Keys(context.Context, ...ScanKeysOption) (*KeyStream, error)
}