Versions in this module Expand all Collapse all v0 v0.6.0 Jul 31, 2025 Changes in this version + type DirErr struct + Dir directory.DirectorySubspace + Err error + type DirKVErr struct + Dir directory.DirectorySubspace + Err error + KV fdb.KeyValue + type KeyValErr struct + Err error + KV keyval.KeyValue + type Option func(*Stream) + func ByteOrder(order binary.ByteOrder) Option + func Logger(log zerolog.Logger) Option + type RangeOpts struct + Limit int + Reverse bool + type Stream struct + func New(ctx context.Context, opts ...Option) Stream + func (x *Stream) OpenDirectories(tr facade.ReadTransactor, query keyval.Directory) chan DirErr + func (x *Stream) ReadRange(tr facade.ReadTransaction, query keyval.Tuple, opts RangeOpts, in chan DirErr) chan DirKVErr + func (x *Stream) SendDir(out chan<- DirErr, in DirErr) bool + func (x *Stream) SendDirKV(out chan<- DirKVErr, in DirKVErr) bool + func (x *Stream) SendKV(out chan<- KeyValErr, in KeyValErr) bool + func (x *Stream) UnpackKeys(query keyval.Tuple, filter bool, in chan DirKVErr) chan KeyValErr + func (x *Stream) UnpackValues(query keyval.Value, filter bool, in chan KeyValErr) chan KeyValErr
Go to main page