keyvalue

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

type KvStore interface {
	// Allow requests the given permissions to the key/value store.
	Allow(permission KvStorePermission, permissions ...KvStorePermission) KvStoreClientIface
}

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

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

type KvStorePermission string

type ScanKeysOption = func(*ScanKeysRequest)

type ScanKeysRequest = v1.KvStoreScanKeysRequest