engine

May 14, 2023

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)

+ 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