store

Documentation

Index

• Variables
• func InitKvStore(cfg config.StoreConfig) (err error)
• func WithKVStore(ctx context.Context, store KVStore) context.Context
• type KVStore
  • func FromContext(ctx context.Context) KVStore
  • func GetKVStore() KVStore
  • func NewConnectorStore(connectorID string) KVStore

Variables

var ErrKeyNotExist = errors.New("key not exist")

Functions

func InitKvStore

func InitKvStore(cfg config.StoreConfig) (err error)

func WithKVStore

func WithKVStore(ctx context.Context, store KVStore) context.Context

Types

type KVStore

type KVStore interface {
	Set(ctx context.Context, key string, value []byte) error
	Get(ctx context.Context, key string) ([]byte, error)
	Delete(ctx context.Context, key string) error
	Close() error
}

func FromContext

func FromContext(ctx context.Context) KVStore

func GetKVStore

func GetKVStore() KVStore

func NewConnectorStore

func NewConnectorStore(connectorID string) KVStore