riverdb

Dec 5, 2023

Changes in this version

type DB

+ func (db *DB) View(fn func(txn *Txn) error) error

type Option

+ func WithMergeCheckPoint(checkPoint float64) Option

+ func WithTxnLevel(level TxnLevel) Option

type Options

+ Level TxnLevel

+ type TxnLevel uint8

+ const ReadCommitted

+ const Serializable

+ func (t TxnLevel) String() string

Dec 4, 2023

Changes in this version

+ var ErrInvalidEvent = errors.New("invalid event")

+ var ErrWatcherClosed = errors.New("watcher is closed")

type DB

+ func (db *DB) Watcher(name string, events ...EventType) (*Watcher, error)

type EventType

+ func (e EventType) String() string

type Options

+ MergeCheckpoint float64

+ type Watcher struct

+ func (w *Watcher) Close() error

+ func (w *Watcher) Listen() (<-chan *Event, error)

+ func (w *Watcher) Name() string

Dec 1, 2023

Changes in this version

+ var ErrBatchClosed = errors.New("batch is closed")

+ type Batch struct

+ func (ba *Batch) DeleteAll(keys []Key) error

+ func (ba *Batch) Effected() int64

+ func (ba *Batch) Error() error

+ func (ba *Batch) Flush() error

+ func (ba *Batch) WriteAll(records []Record) error

+ type BatchOption struct

+ Size int64

+ SyncOnFlush bool

+ SyncPerBatch bool

+ type BitFlag uint64

+ func (bf *BitFlag) Check(flags ...uint64) bool

+ func (bf *BitFlag) Revoke(flags ...uint64)

+ func (bf *BitFlag) Store(flags ...uint64)

type DB

+ func (db *DB) Batch(opt BatchOption) (*Batch, error)

+ func (db *DB) Stats() Stats

+ type Record struct

+ K Key

+ TTL time.Duration

+ V Value

+ type Stats struct

+ DataSize int64

+ HintSize int64

+ KeyNums int64

+ RecordNums int64

Nov 28, 2023

Changes in this version

+ var ErrWatcherDisabled = errors.New("event watcher disabled")

type DB

+ func OpenWithCtx(ctx context.Context, options Options, opts ...Option) (*DB, error)

+ func (db *DB) Backup(destpath string) error

+ func (db *DB) Recover(srcpath string) error

+ func (db *DB) Watch() (<-chan *Event, error)

+ type Event struct

+ Type EventType

+ Value any

+ type EventType uint

+ const BackupEvent

+ const DelEvent

+ const MergeEvent

+ const PutEvent

+ const RecoverEvent

+ const RollbackEvent

+ type Mask uint32

+ func (m *Mask) CheckAny(ms ...uint32) bool

+ func (m *Mask) CheckSome(ms ...uint32) bool

+ func (m *Mask) Remove(ms ...uint32)

+ func (m *Mask) Store(ms ...uint32)

type Option

+ func WithWatchEvent(events ...EventType) Option

+ func WithWatchSize(size int) Option

type Options

+ WatchEvents []EventType

+ WatchSize int

Nov 24, 2023

Changes in this version

+ var DefaultOptions = Options

+ var ErrDBClosed = errors.New("db is already closed")

+ var ErrDBMerging = errors.New("db is merging data")

+ var ErrDirAlreadyUsed = errors.New("dir already used by another process")

+ var ErrKeyNotFound = errors.New("key not found")

+ var ErrMergedNotFinished = errors.New("merged not finished")

+ var ErrNilKey = entry.ErrNilKey

+ var ErrTxnClosed = errors.New("transaction is closed")

+ var ErrTxnConflict = errors.New("transaction is conflict")

+ var ErrTxnReadonly = errors.New("transaction is read-only")

+ func FastRand() uint32

+ type DB struct

+ func Open(options Options, opts ...Option) (*DB, error)

+ func (db *DB) Begin(readonly bool) (*Txn, error)

+ func (db *DB) Close() error

+ func (db *DB) Del(key Key) error

+ func (db *DB) Expire(key Key, ttl time.Duration) error

+ func (db *DB) Get(key Key) (Value, error)

+ func (db *DB) Merge(transfer bool) error

+ func (db *DB) Purge() error

+ func (db *DB) Put(key Key, value Value, ttl time.Duration) error

+ func (db *DB) Range(option RangeOptions, handler RangeHandler) error

+ func (db *DB) Sync() error

+ func (db *DB) TTL(key Key) (time.Duration, error)

+ type Key = []byte

+ type Option func(option *Options)

+ func WithBlockCache(block uint32) Option

+ func WithClosedGc(gc bool) Option

+ func WithCompare(compare index.Compare) Option

+ func WithDir(dir string) Option

+ func WithFsync(sync bool) Option

+ func WithFsyncThreshold(threshold int64) Option

+ func WithMaxSize(size int64) Option

+ type Options struct

+ BlockCache uint32

+ ClosedGc bool

+ Compare index.Compare

+ Dir string

+ Fsync bool

+ FsyncThreshold int64

+ MaxSize int64

+ type RangeHandler = func(key Key) bool

+ type RangeOptions = index.RangeOption

+ type Txn struct

+ func (txn *Txn) Commit() error

+ func (txn *Txn) Del(key Key) error

+ func (txn *Txn) Expire(key Key, ttl time.Duration) error

+ func (txn *Txn) Get(key Key) (Value, error)

+ func (txn *Txn) Put(key Key, value Value, ttl time.Duration) error

+ func (txn *Txn) Range(opt RangeOptions, handler RangeHandler) error

+ func (txn *Txn) RollBack() error

+ func (txn *Txn) TTL(key Key) (time.Duration, error)

+ type Value = []byte