Versions in this module Expand all Collapse all v0 v0.1.0 Nov 5, 2024 Changes in this version + var ErrConditionFailed = errors.New("error during condition") + var ErrDeleteAllFailed = errors.New("error during delete-all") + var ErrDeleteFailed = errors.New("error during delete") + var ErrDeleteIfFailed = errors.New("error during delete-if") + var ErrGetAllFailed = errors.New("error during get-all") + var ErrGetAllKeysFailed = errors.New("error during get-all-keys") + var ErrGetBatchFailed = errors.New("error during get-batch") + var ErrGetFailed = errors.New("error during get") + var ErrGetFirstFailed = errors.New("error during get-first") + var ErrKeyAlreadyExists = errors.New("key already exists in storage") + var ErrKeyNotFound = errors.New("key not found in storage") + var ErrMoveFailed = errors.New("error during move") + var ErrMoveReplaceFailed = errors.New("error during move-replace") + var ErrSetEmptyFailed = errors.New("error during set-empty") + var ErrSetFailed = errors.New("error during set") + var ErrSetIfFailed = errors.New("error during set-if") + var ErrSubscriptionFailed = errors.New("error during subscription") + type Condition func(version uint64) (condition bool) + type Entries []Entry + type Entry struct + Key string + Value []byte + Version uint64 + type KVStore interface + Close func() error + Delete func(ctx context.Context, key string) (err error) + DeleteAll func(ctx context.Context, prefix string) (err error) + DeleteIf func(ctx context.Context, key string, condition Condition) (err error) + Exists func(ctx context.Context, key string) (exists bool, err error) + Get func(ctx context.Context, key string) (value []byte, version uint64, err error) + GetAll func(ctx context.Context, prefix string) (entries Entries, err error) + GetAllKeys func(ctx context.Context, prefix string) (keys []string, err error) + GetBatch func(ctx context.Context, keys ...string) (entries Entries, err error) + GetFirst func(ctx context.Context, prefix string) (entry *Entry, err error) + GetLimit func(ctx context.Context, prefix string, limit int64) (entries Entries, err error) + Move func(ctx context.Context, oldKey string, newKey string) (err error) + MoveReplace func(ctx context.Context, oldKey string, newKey string, value []byte) (err error) + MoveReplaceIf func(ctx context.Context, oldKey string, newKey string, value []byte, ...) (err error) + Set func(ctx context.Context, key string, value []byte) (err error) + SetDelete func(ctx context.Context, key string, value []byte, delete string) (err error) + SetEmpty func(ctx context.Context, key string) (err error) + SetExpiry func(ctx context.Context, key string, value []byte, ttl time.Duration) error + SetIf func(ctx context.Context, key string, value []byte, condition Condition) (err error) + SetIfNotExist func(ctx context.Context, key string, value []byte) (err error) + SetIfNotExistExpiry func(ctx context.Context, key string, value []byte, ttl time.Duration) (err error) + Subscribe func(ctx context.Context, prefix string, handler SubscriptionHandler) error + type SubscriptionHandler func(key string, value []byte, version uint64, deleted bool) error
Go to main page