local

Nov 1, 2025

Changes in this version

type WarpTransactioner

+ GetExpiration func(key DatabaseKey) (uint64, error)

Oct 23, 2025

Changes in this version

+ func ToDatatoreErrNotFound(err error) error

Oct 23, 2025

Changes in this version

type WarpTransactioner

+ ListKeys func(prefix DatabaseKey, limit *uint64, cursor *string) ([]string, string, error)

type WarpTxn

+ func (t *WarpTxn) ListKeys(prefix DatabaseKey, limit *uint64, cursor *string) ([]string, string, error)

Oct 19, 2025

Changes in this version

+ type Transporter interface

+ Addrs func() []multiaddr.Multiaddr

+ Close func() error

+ ConnManager func() connmgr.ConnManager

+ Connect func(ctx context.Context, pi peer.AddrInfo) error

+ EventBus func() event.Bus

+ ID func() peer.ID

+ Mux func() protocol.Switch

+ Network func() network.Network

+ NewStream func(ctx context.Context, p peer.ID, pids ...protocol.ID) (network.Stream, error)

+ Peerstore func() peerstore.Peerstore

+ RemoveStreamHandler func(pid protocol.ID)

+ SetStreamHandler func(pid protocol.ID, handler network.StreamHandler)

+ SetStreamHandlerMatch func(protocol.ID, func(protocol.ID) bool, network.StreamHandler)

Oct 19, 2025

Changes in this version

+ type Broadcaster = crdt.Broadcaster

type DB

+ func (db *DB) BatchGet(keys ...DatabaseKey) ([]ListItem, error)

+ func (db *DB) BatchSet(data []ListItem) (err error)

+ func (db *DB) EnableCRDT(ns string, b Broadcaster) (err error)

+ func (db *DB) LocalStore() LocalStore

+ type LocalStore interface

+ type PubSubProvider interface

+ Close func() error

+ PublishUpdateToFollowers func(ownerId, dest string, bt []byte) (err error)

+ SubscribeUserUpdate func(userId string) (err error)

+ UnsubscribeUserUpdate func(userId string) (err error)

Oct 20, 2025

Changes in this version

+ const PermanentTTL

+ var DefaultIteratorOptions = badger.DefaultIteratorOptions

+ var ErrDatastoreKeyNotFound = &ds.ErrNotFound

+ func IsNotFoundError(err error) bool

+ func NewKey(s string) ds.Key

+ type Batch = ds.Batch

+ type Batching = ds.Batching

+ type DsEntry = dsq.Entry

+ type Entry = badger.Entry

+ type Filter = dsq.Filter

+ type Item = badger.Item

+ type Key = ds.Key

+ type Options struct

+ func DefaultOptions() *Options

+ func (opt *Options) WithDiscardRatioGC(ratio float64) *Options

+ func (opt *Options) WithInMemory(v bool) *Options

+ func (opt *Options) WithIntervalGC(interval time.Duration) *Options

+ func (opt *Options) WithSleepGC(sleep time.Duration) *Options

+ type OrderByKey = dsq.OrderByKey

+ type OrderByKeyDescending = dsq.OrderByKeyDescending

+ type Query = dsq.Query

+ type Result = dsq.Result

+ type Results = dsq.Results

+ func NaiveQueryApply(q Query, qr Results) Results

+ func ResultsReplaceQuery(r Results, q Query) Results

+ func ResultsWithContext(q Query, proc func(context.Context, chan<- Result)) Results

+ type WriteBatch = badger.WriteBatch

Jun 21, 2025

Changes in this version

+ const Delimeter

+ const FixedKey

+ const FixedRangeKey

+ const NoneRangeKey

+ var ErrKeyNotFound = badger.ErrKeyNotFound

+ var ErrNotRunning = DBError("DB is not running")

+ var ErrStopIteration = DBError("stop iteration")

+ var ErrWrongPassword = DBError("wrong username or password")

+ type DB struct

+ func New(path string, isInMemory bool, dataFolder string) (*DB, error)

+ func (db *DB) Close()

+ func (db *DB) Delete(key DatabaseKey) error

+ func (db *DB) GC()

+ func (db *DB) Get(key DatabaseKey) ([]byte, error)

+ func (db *DB) GetExpiration(key DatabaseKey) (uint64, error)

+ func (db *DB) GetSize(key DatabaseKey) (int64, error)

+ func (db *DB) InnerDB() *badger.DB

+ func (db *DB) IsClosed() bool

+ func (db *DB) IsFirstRun() bool

+ func (db *DB) NewTxn() (WarpTransactioner, error)

+ func (db *DB) NextSequence() (uint64, error)

+ func (db *DB) Path() string

+ func (db *DB) Run(username, password string) (err error)

+ func (db *DB) Set(key DatabaseKey, value []byte) error

+ func (db *DB) SetWithTTL(key DatabaseKey, value []byte, ttl time.Duration) error

+ func (db *DB) Stats() map[string]string

+ func (db *DB) Sync() error

+ type DBError string

+ func (e DBError) Error() string

+ type DatabaseKey string

+ func (k DatabaseKey) Bytes() []byte

+ func (k DatabaseKey) DropId() string

+ func (k DatabaseKey) IsEmpty() bool

+ func (k DatabaseKey) String() string

+ type IdLayer string

+ func (l IdLayer) AddId(mandatoryPrefix string) IdLayer

+ func (l IdLayer) AddReversedTimestamp(tm time.Time) RangeLayer

+ func (l IdLayer) Build() DatabaseKey

+ type IterKeysFunc func(key string) error

+ type ListItem struct

+ Key string

+ Value []byte

+ type Namespace string

+ func NewPrefixBuilder(mandatoryNamespace string) Namespace

+ func (ns Namespace) AddRootID(mandatoryPrefix string) ParentLayer

+ func (ns Namespace) AddSubPrefix(p string) Namespace

+ func (ns Namespace) Build() DatabaseKey

+ type ParentLayer string

+ func (l ParentLayer) AddParentId(mandatoryPrefix string) IdLayer

+ func (l ParentLayer) AddRange(mandatoryPrefix RangePrefix) RangeLayer

+ func (l ParentLayer) AddReversedTimestamp(tm time.Time) RangeLayer

+ func (l ParentLayer) Build() DatabaseKey

+ type PrefixBuilder struct

+ func (pb *PrefixBuilder) AddReaderId(readerId string) *PrefixBuilder

+ func (pb *PrefixBuilder) AddWriterId(writerId string) *PrefixBuilder

+ type RangeLayer string

+ func (l RangeLayer) AddParentId(mandatoryPrefix string) IdLayer

+ func (l RangeLayer) Build() DatabaseKey

+ type RangePrefix string

+ type Txn = badger.Txn

+ type WarpDB = badger.DB

+ type WarpDBLogger interface

+ Debugf func(string, ...interface{})

+ Errorf func(string, ...interface{})

+ Infof func(string, ...interface{})

+ Warningf func(string, ...interface{})

+ type WarpTransactioner interface

+ BatchGet func(keys ...DatabaseKey) ([]ListItem, error)

+ BatchSet func(data []ListItem) (err error)

+ Commit func() error

+ Decrement func(key DatabaseKey) (uint64, error)

+ Delete func(key DatabaseKey) error

+ Discard func() error

+ Get func(key DatabaseKey) ([]byte, error)

+ Increment func(key DatabaseKey) (uint64, error)

+ IterateKeys func(prefix DatabaseKey, handler IterKeysFunc) error

+ List func(prefix DatabaseKey, limit *uint64, cursor *string) ([]ListItem, string, error)

+ ReverseIterateKeys func(prefix DatabaseKey, handler IterKeysFunc) error

+ Rollback func()

+ Set func(key DatabaseKey, value []byte) error

+ SetWithTTL func(key DatabaseKey, value []byte, ttl time.Duration) error

+ type WarpTxn struct

+ func (t *WarpTxn) BatchGet(keys ...DatabaseKey) ([]ListItem, error)

+ func (t *WarpTxn) BatchSet(data []ListItem) (err error)

+ func (t *WarpTxn) Commit() error

+ func (t *WarpTxn) Decrement(key DatabaseKey) (uint64, error)

+ func (t *WarpTxn) Delete(key DatabaseKey) error

+ func (t *WarpTxn) Discard() error

+ func (t *WarpTxn) Get(key DatabaseKey) ([]byte, error)

+ func (t *WarpTxn) Increment(key DatabaseKey) (uint64, error)

+ func (t *WarpTxn) IterateKeys(prefix DatabaseKey, handler IterKeysFunc) error

+ func (t *WarpTxn) List(prefix DatabaseKey, limit *uint64, cursor *string) ([]ListItem, string, error)

+ func (t *WarpTxn) ReverseIterateKeys(prefix DatabaseKey, handler IterKeysFunc) error

+ func (t *WarpTxn) Rollback()

+ func (t *WarpTxn) Set(key DatabaseKey, value []byte) error

+ func (t *WarpTxn) SetWithTTL(key DatabaseKey, value []byte, ttl time.Duration) error