kv

Nov 16, 2025

Changes in this version

+ var ErrBucketAlreadyExists = errors.New("bucket already exists")

+ var ErrBucketNotFound = errors.New("bucket not found")

+ var ErrKeyNotFound = errors.New("key not found")

+ var ErrTransactionAlreadyOpen = errors.New("transaction already open")

+ type StoreLister interface

+ List func(ctx context.Context) ([]OBJECT, error)

+ type StoreListerTx interface

+ List func(ctx context.Context, tx Tx) ([]OBJECT, error)

+ type StoreStreamer interface

+ Stream func(ctx context.Context, ch chan<- OBJECT) error

+ type StoreStreamerTx interface

+ Stream func(ctx context.Context, tx Tx, ch chan<- OBJECT) error

Sep 25, 2025

Changes in this version

+ type StoreList interface

+ List func(ctx context.Context) ([]OBJECT, error)

+ type StoreListTx interface

+ List func(ctx context.Context, tx Tx) ([]OBJECT, error)

May 18, 2025

Changes in this version

+ type FuncTx func(ctx context.Context, tx Tx) error

+ func (r FuncTx) Run(ctx context.Context, tx Tx) error

+ type RunnableTx interface

+ Run func(ctx context.Context, tx Tx) error

Apr 2, 2025

Changes in this version

type Store

+ func NewStoreFromTx[KEY ~[]byte | ~string, OBJECT any](db DB, storeTx StoreTx[KEY, OBJECT]) Store[KEY, OBJECT]

Mar 30, 2025

Changes in this version

type DB

+ func NewDBWithMetrics(db DB, metrics Metrics) DB

+ type Metrics interface

+ DbUpdateInc func()

+ DbViewInc func()

+ func NewMetrics() Metrics

Feb 6, 2025

Changes in this version

type RelationStore

+ func NewRelationStoreFromRelationStoreTx[ID ~[]byte | ~string, RelatedID ~[]byte | ~string](db DB, storeTx RelationStoreTx[ID, RelatedID]) RelationStore[ID, RelatedID]

+ Invert func() RelationStore[RelatedID, ID]

type RelationStoreTx

+ func NewRelationStoreTxWithBucket[ID ~[]byte | ~string, RelatedID ~[]byte | ~string](idRelationBucket StoreTx[ID, []RelatedID], ...) RelationStoreTx[ID, RelatedID]

+ Invert func() RelationStoreTx[RelatedID, ID]

Feb 3, 2025

Changes in this version

type RelationStore

+ MapIDRelations func(ctx context.Context, ...) error

+ MapRelationIDs func(ctx context.Context, ...) error

type RelationStoreTx

+ MapIDRelations func(ctx context.Context, tx Tx, ...) error

+ MapRelationIDs func(ctx context.Context, tx Tx, ...) error

Jan 10, 2025

Changes in this version

+ var BucketAlreadyExistsError = errors.New("bucket already exists")

+ var BucketNotFoundError = errors.New("bucket not found")

+ var KeyNotFoundError = errors.New("key not found")

+ var TransactionAlreadyOpenError = errors.New("transaction already open")

+ func BasicTestSuite(provider Provider)

+ func BucketTestSuite(provider Provider)

+ func Count(ctx context.Context, bucket Bucket) (int64, error)

+ func ForEach(ctx context.Context, bucket Bucket, fn func(item Item) error) error

+ func IteratorTestSuite(provider Provider)

+ func NewJsonHandlerUpdateTx(db DB, jsonHandler JsonHandlerTx) libhttp.WithError

+ func NewJsonHandlerViewTx(db DB, jsonHandler JsonHandlerTx) libhttp.WithError

+ func NewResetBucketHandler(db DB, cancel context.CancelFunc) http.Handler

+ func NewResetHandler(db DB, cancel context.CancelFunc) http.Handler

+ func RelationStoreTestSuite(provider Provider)

+ type Bucket interface

+ Delete func(ctx context.Context, bytes []byte) error

+ Get func(ctx context.Context, bytes []byte) (Item, error)

+ Iterator func() Iterator

+ IteratorReverse func() Iterator

+ Put func(ctx context.Context, key []byte, value []byte) error

+ type BucketName []byte

+ func BucketFromStrings(values ...string) BucketName

+ func NewBucketName(name string) BucketName

+ func (b BucketName) Bytes() []byte

+ func (b BucketName) Equal(value BucketName) bool

+ func (b BucketName) String() string

+ type BucketNames []BucketName

+ func (t BucketNames) Contains(value BucketName) bool

+ type DB interface

+ Close func() error

+ Remove func() error

+ Sync func() error

+ Update func(ctx context.Context, fn func(ctx context.Context, tx Tx) error) error

+ View func(ctx context.Context, fn func(ctx context.Context, tx Tx) error) error

+ type Item interface

+ Exists func() bool

+ Key func() []byte

+ Value func(fn func(val []byte) error) error

+ func NewByteItem(key []byte, value []byte) Item

+ type Iterator interface

+ Close func()

+ Item func() Item

+ Next func()

+ Rewind func()

+ Seek func(key []byte)

+ Valid func() bool

+ type JsonHandlerTx interface

+ ServeHTTP func(ctx context.Context, tx Tx, req *http.Request) (interface{}, error)

+ type JsonHandlerTxFunc func(ctx context.Context, tx Tx, req *http.Request) (interface{}, error)

+ func (j JsonHandlerTxFunc) ServeHTTP(ctx context.Context, tx Tx, req *http.Request) (interface{}, error)

+ type Key []byte

+ func (f Key) Bytes() []byte

+ func (f Key) String() string

+ type Provider interface

+ Get func(ctx context.Context) (DB, error)

+ type ProviderFunc func(ctx context.Context) (DB, error)

+ func (p ProviderFunc) Get(ctx context.Context) (DB, error)

+ type RelationStore interface

+ Add func(ctx context.Context, id ID, relatedIds []RelatedID) error

+ Delete func(ctx context.Context, id ID) error

+ IDs func(ctx context.Context, relatedId RelatedID) ([]ID, error)

+ RelatedIDs func(ctx context.Context, id ID) ([]RelatedID, error)

+ Remove func(ctx context.Context, id ID, relatedIds []RelatedID) error

+ Replace func(ctx context.Context, id ID, relatedIds []RelatedID) error

+ StreamIDs func(ctx context.Context, ch chan<- ID) error

+ StreamRelatedIDs func(ctx context.Context, ch chan<- RelatedID) error

+ func NewRelationStore[ID ~[]byte | ~string, RelatedID ~[]byte | ~string](db DB, name string) RelationStore[ID, RelatedID]

+ type RelationStoreString RelationStore[string, string]

+ type RelationStoreTx interface

+ Add func(ctx context.Context, tx Tx, id ID, relatedIds []RelatedID) error

+ Delete func(ctx context.Context, tx Tx, id ID) error

+ IDs func(ctx context.Context, tx Tx, relatedId RelatedID) ([]ID, error)

+ RelatedIDs func(ctx context.Context, tx Tx, id ID) ([]RelatedID, error)

+ Remove func(ctx context.Context, tx Tx, id ID, relatedIds []RelatedID) error

+ Replace func(ctx context.Context, tx Tx, id ID, relatedIds []RelatedID) error

+ StreamIDs func(ctx context.Context, tx Tx, ch chan<- ID) error

+ StreamRelatedIDs func(ctx context.Context, tx Tx, ch chan<- RelatedID) error

+ func NewRelationStoreTx[ID ~[]byte | ~string, RelatedID ~[]byte | ~string](name string) RelationStoreTx[ID, RelatedID]

+ type RelationStoreTxString RelationStoreTx[string, string]

+ type Store interface

+ func NewStore[KEY ~[]byte | ~string, OBJECT any](db DB, bucketName BucketName) Store[KEY, OBJECT]

+ type StoreAdder interface

+ Add func(ctx context.Context, key KEY, object OBJECT) error

+ type StoreAdderTx interface

+ Add func(ctx context.Context, tx Tx, key KEY, object OBJECT) error

+ type StoreExists interface

+ Exists func(ctx context.Context, key KEY) (bool, error)

+ type StoreExistsTx interface

+ Exists func(ctx context.Context, tx Tx, key KEY) (bool, error)

+ type StoreGetter interface

+ Get func(ctx context.Context, key KEY) (*OBJECT, error)

+ type StoreGetterTx interface

+ Get func(ctx context.Context, tx Tx, key KEY) (*OBJECT, error)

+ type StoreMapper interface

+ Map func(ctx context.Context, ...) error

+ type StoreMapperTx interface

+ Map func(ctx context.Context, tx Tx, ...) error

+ type StoreRemover interface

+ Remove func(ctx context.Context, key KEY) error

+ type StoreRemoverTx interface

+ Remove func(ctx context.Context, tx Tx, key KEY) error

+ type StoreStream interface

+ Stream func(ctx context.Context, ch chan<- OBJECT) error

+ type StoreStreamTx interface

+ Stream func(ctx context.Context, tx Tx, ch chan<- OBJECT) error

+ type StoreTx interface

+ func NewStoreTx[KEY ~[]byte | ~string, OBJECT any](bucketName BucketName) StoreTx[KEY, OBJECT]

+ type Tx interface

+ Bucket func(ctx context.Context, name BucketName) (Bucket, error)

+ CreateBucket func(ctx context.Context, name BucketName) (Bucket, error)

+ CreateBucketIfNotExists func(ctx context.Context, name BucketName) (Bucket, error)

+ DeleteBucket func(ctx context.Context, name BucketName) error

+ ListBucketNames func(ctx context.Context) (BucketNames, error)