filekv

Nov 16, 2022

Changes in this version

+ var BufferSize = 50 * 1024 * 1024

+ var ErrItemExists = errors.New("item already exist")

+ var ErrItemFiltered = errors.New("item filtered")

+ var FpRatio = 0.0001

+ var MaxItems = uint(math.MaxInt32)

+ var NewLine = "\n"

+ var Separator = ";;;"

+ type FileDB struct

+ func Open(options Options) (*FileDB, error)

+ func (f *FileDB) Merge(items ...interface{}) (uint, error)

+ func (f *FileDB) MergeFile(filename string) (uint, error)

+ func (f *FileDB) MergeReader(reader io.Reader) (uint, error)

+ func (fdb *FileDB) Close()

+ func (fdb *FileDB) Process() error

+ func (fdb *FileDB) Reset() error

+ func (fdb *FileDB) Scan(handler func([]byte, []byte) error) error

+ func (fdb *FileDB) Set(k, v []byte) error

+ func (fdb *FileDB) Size() int64

+ type Options struct

+ Cleanup bool

+ Compress bool

+ Dedupe Strategy

+ FilterCallback func(k, v []byte) bool

+ MaxItems uint

+ Path string

+ SkipEmpty bool

+ var DefaultOptions Options = Options{ ... }

+ type Stats struct

+ NumberOfAddedItems uint

+ NumberOfDupedItems uint

+ NumberOfFilteredItems uint

+ NumberOfItems uint

+ type Strategy uint8

+ const DiskFilter

+ const MemoryFilter

+ const MemoryLRU

+ const MemoryMap

+ const None