Versions in this module Expand all Collapse all v0 v0.6.0 Jul 31, 2025 Changes in this version + type Engine struct + func New(tr facade.Transactor, opts ...Option) Engine + func (x *Engine) Clear(query keyval.KeyValue) error + func (x *Engine) Directories(ctx context.Context, query keyval.Directory) chan stream.DirErr + func (x *Engine) ReadRange(ctx context.Context, query keyval.KeyValue, opts RangeOpts) chan stream.KeyValErr + func (x *Engine) ReadSingle(query keyval.KeyValue, opts SingleOpts) (*keyval.KeyValue, error) + func (x *Engine) Set(query keyval.KeyValue) error + func (x *Engine) Transact(f func(Engine) (interface{}, error)) (interface{}, error) + func (x *Engine) Watch(query keyval.KeyValue) (fdb.FutureNil, error) + type Option func(*Engine) + func ByteOrder(order binary.ByteOrder) Option + func Logger(log zerolog.Logger) Option + type RangeOpts struct + Filter bool + Limit int + Reverse bool + type SingleOpts struct + Filter bool