rosedb

Jan 7, 2024

Changes in this version

type Options

+ AutoMergeCronExpr string

Sep 16, 2023

Changes in this version

type Batch

+ func (b *Batch) Persist(key []byte) error

type DB

+ func (db *DB) Persist(key []byte) error

Aug 30, 2023

Changes in this version

type Batch

+ func (b *Batch) Expire(key []byte, ttl time.Duration) error

+ func (b *Batch) TTL(key []byte) (time.Duration, error)

type DB

+ func (db *DB) AscendKeys(pattern []byte, handleFn func(k []byte) (bool, error))

+ func (db *DB) DeleteExpiredKeys(timeout time.Duration) error

+ func (db *DB) DescendKeys(pattern []byte, handleFn func(k []byte) (bool, error))

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

+ func (db *DB) TTL(key []byte) (time.Duration, error)

type LogRecord

+ func (lr *LogRecord) IsExpired(now int64) bool

Aug 21, 2023

Changes in this version

type Batch

+ func (b *Batch) PutWithTTL(key []byte, value []byte, ttl time.Duration) error

type DB

+ func (db *DB) AscendGreaterOrEqual(key []byte, handleFn func(k []byte, v []byte) (bool, error))

+ func (db *DB) AscendRange(startKey, endKey []byte, handleFn func(k []byte, v []byte) (bool, error))

+ func (db *DB) DescendLessOrEqual(key []byte, handleFn func(k []byte, v []byte) (bool, error))

+ func (db *DB) DescendRange(startKey, endKey []byte, handleFn func(k []byte, v []byte) (bool, error))

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

type LogRecord

+ Expire int64

Aug 18, 2023

Changes in this version

type DB

+ func (db *DB) Ascend(handleFn func(k []byte, v []byte) (bool, error))

+ func (db *DB) Descend(handleFn func(k []byte, v []byte) (bool, error))

Aug 5, 2023

Changes in this version

+ var ErrWatchDisabled = errors.New("the watch is disabled")

type DB

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

+ type Event struct

+ Action WatchActionType

+ BatchId uint64

+ Key []byte

+ Value []byte

type Options

+ WatchQueueSize uint64

+ type WatchActionType = byte

+ const WatchActionDelete

+ const WatchActionPut

+ type Watcher struct

+ func NewWatcher(capacity uint64) *Watcher

Jul 3, 2023

Changes in this version

+ var ErrBatchRollbacked = errors.New("the batch is rollbacked")

type Batch

+ func (b *Batch) Rollback() error

Jun 21, 2023

Changes in this version

+ var ErrMergeRunning = errors.New("the merge operation is running")

type DB

+ func (db *DB) Merge() error

Jun 15, 2023

Changes in this version

+ var DefaultIteratorOptions = IteratorOptions

type DB

+ func (db *DB) NewIterator(options IteratorOptions) *Iterator

+ type Iterator struct

+ func (it *Iterator) Close()

+ func (it *Iterator) Key() []byte

+ func (it *Iterator) Next()

+ func (it *Iterator) Rewind()

+ func (it *Iterator) Seek(key []byte)

+ func (it *Iterator) Valid() bool

+ func (it *Iterator) Value() ([]byte, error)

+ type IteratorOptions struct

+ Prefix []byte

+ Reverse bool

Jun 13, 2023

Changes in this version

+ const B

+ const GB

+ const KB

+ const MB

+ var DefaultBatchOptions = BatchOptions

+ var DefaultOptions = Options

+ var ErrBatchCommitted = errors.New("the batch is committed")

+ var ErrDBClosed = errors.New("the database is closed")

+ var ErrDatabaseIsUsing = errors.New("the database directory is used by another process")

+ var ErrKeyIsEmpty = errors.New("the key is empty")

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

+ var ErrReadOnlyBatch = errors.New("the batch is read only")

+ type Batch struct

+ func (b *Batch) Commit() error

+ func (b *Batch) Delete(key []byte) error

+ func (b *Batch) Exist(key []byte) (bool, error)

+ func (b *Batch) Get(key []byte) ([]byte, error)

+ func (b *Batch) Put(key []byte, value []byte) error

+ type BatchOptions struct

+ ReadOnly bool

+ Sync bool

+ type DB struct

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

+ func (db *DB) Close() error

+ func (db *DB) Delete(key []byte) error

+ func (db *DB) Exist(key []byte) (bool, error)

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

+ func (db *DB) NewBatch(options BatchOptions) *Batch

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

+ func (db *DB) Stat() *Stat

+ func (db *DB) Sync() error

+ type IndexRecord struct

+ type LogRecord struct

+ BatchId uint64

+ Key []byte

+ Type LogRecordType

+ Value []byte

+ type LogRecordType = byte

+ const LogRecordBatchFinished

+ const LogRecordDeleted

+ const LogRecordNormal

+ type Options struct

+ BlockCache uint32

+ BytesPerSync uint32

+ DirPath string

+ SegmentSize int64

+ Sync bool

+ type Stat struct

+ DiskSize int64

+ KeysNum int