Versions in this module Expand all Collapse all v0 v0.0.0 Jul 4, 2022 Changes in this version + const CleanPrefix + const DirtyPrefix + type Flushable struct + func Wrap(parent kvdb.DropableStore) *Flushable + func WrapWithDrop(parent kvdb.Store, drop func()) *Flushable + func (w *Flushable) Close() error + func (w *Flushable) Compact(start []byte, limit []byte) error + func (w *Flushable) Delete(key []byte) error + func (w *Flushable) Drop() + func (w *Flushable) DropNotFlushed() + func (w *Flushable) Flush() error + func (w *Flushable) Get(key []byte) ([]byte, error) + func (w *Flushable) Has(key []byte) (bool, error) + func (w *Flushable) NewBatch() kvdb.Batch + func (w *Flushable) NewIterator(prefix []byte, start []byte) kvdb.Iterator + func (w *Flushable) NotFlushedPairs() int + func (w *Flushable) NotFlushedSizeEst() int + func (w *Flushable) Put(key []byte, value []byte) error + func (w *Flushable) Stat(property string) (string, error) + type LazyFlushable struct + func NewLazy(producer func() (kvdb.DropableStore, error), drop func()) *LazyFlushable + func (w *LazyFlushable) Flush() (err error) + func (w *LazyFlushable) InitUnderlyingDb() (kvdb.Store, error) + type SyncedPool struct + func NewSyncedPool(producer kvdb.DBProducer, flushIDKey []byte) *SyncedPool + func (p *SyncedPool) Close() error + func (p *SyncedPool) Flush(id []byte) error + func (p *SyncedPool) GetUnderlying(name string) (kvdb.ReadonlyStore, error) + func (p *SyncedPool) Initialize(dbNames []string) error + func (p *SyncedPool) NotFlushedSizeEst() int + func (p *SyncedPool) OpenDB(name string) (kvdb.DropableStore, error)
Go to main page