bitcaskdb

Jun 24, 2022

Changes in this version

type Bitcask

+ func (b *Bitcask) MergeWithWaitLimit(lim *rate.Limiter) error

+ func (b *Bitcask) MergeWithWaitLimitByBytesPerSecond(bytesPerSecond int) error

Jun 24, 2022

Changes in this version

type Stats

+ ReclaimableSpace int64

Jun 20, 2022

Changes in this version

+ const AppName

+ const DefaultCopyTempThrshold

+ const DefaultDirFileModeBeforeUmask

+ const DefaultFileFileModeBeforeUmask

+ const DefaultMaxDatafileSize

+ const DefaultNoRepliEmit

+ const DefaultNoRepliRecv

+ const DefaultRepliBindIP

+ const DefaultRepliBindPort

+ const DefaultRepliRequestTimeout

+ const DefaultRepliServerIP

+ const DefaultRepliServerPort

+ const DefaultSync

+ const DefaultValueOnMemoryThreshold

+ const Version

+ var ErrDatabaseLocked = errors.New("error: database locked")

+ var ErrEmptyKey = errors.New("error: empty key")

+ var ErrInvalidRange = errors.New("error: invalid range")

+ var ErrInvalidVersion = errors.New("error: invalid db version")

+ var ErrKeyExpired = errors.New("error: key expired")

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

+ var ErrKeyTooLarge = errors.New("error: key too large")

+ var ErrMergeInProgress = errors.New("error: merge already in progress")

+ var ErrValueTooLarge = errors.New("error: value too large")

+ type Bitcask struct

+ func Open(path string, funcs ...OptionFunc) (*Bitcask, error)

+ func (b *Bitcask) Close() error

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

+ func (b *Bitcask) DeleteAll() (err error)

+ func (b *Bitcask) Fold(f func(key []byte) error) (err error)

+ func (b *Bitcask) Get(key []byte) (io.ReadCloser, error)

+ func (b *Bitcask) Has(key []byte) bool

+ func (b *Bitcask) Keys() chan []byte

+ func (b *Bitcask) Len() int

+ func (b *Bitcask) Merge() error

+ func (b *Bitcask) Put(key []byte, value io.Reader) error

+ func (b *Bitcask) PutBytes(key, value []byte) error

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

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

+ func (b *Bitcask) Range(start, end []byte, f func(key []byte) error) (err error)

+ func (b *Bitcask) Reclaimable() int64

+ func (b *Bitcask) Reopen() error

+ func (b *Bitcask) RunGC() error

+ func (b *Bitcask) Scan(prefix []byte, f func(key []byte) error) (err error)

+ func (b *Bitcask) Sift(f func(key []byte) (bool, error)) (err error)

+ func (b *Bitcask) SiftRange(start, end []byte, f func(key []byte) (bool, error)) (err error)

+ func (b *Bitcask) SiftScan(prefix []byte, f func(key []byte) (bool, error)) (err error)

+ func (b *Bitcask) Stats() (Stats, error)

+ func (b *Bitcask) Sync() error

+ type ErrBadConfig struct

+ Err error

+ func (e *ErrBadConfig) Error() string

+ func (e *ErrBadConfig) Is(target error) bool

+ func (e *ErrBadConfig) Unwrap() error

+ type ErrBadMetadata struct

+ Err error

+ func (e *ErrBadMetadata) Error() string

+ func (e *ErrBadMetadata) Is(target error) bool

+ func (e *ErrBadMetadata) Unwrap() error

+ type OptionFunc func(*option) error

+ func WithCopyTempThreshold(size int64) OptionFunc

+ func WithDirFileModeBeforeUmask(mode os.FileMode) OptionFunc

+ func WithFileFileModeBeforeUmask(mode os.FileMode) OptionFunc

+ func WithLogger(logger *log.Logger) OptionFunc

+ func WithMaxDatafileSize(size int) OptionFunc

+ func WithRepli(bindIP string, bindPort int) OptionFunc

+ func WithRepliClient(serverIP string, serverPort int) OptionFunc

+ func WithRepliClientRequestTimeout(rto time.Duration) OptionFunc

+ func WithRuntimeContext(ctx runtime.Context) OptionFunc

+ func WithSync(sync bool) OptionFunc

+ func WithTempDir(dir string) OptionFunc

+ func WithValidateChecksum(enable bool) OptionFunc

+ func WithValueOnMemoryThreshold(size int64) OptionFunc

+ type Stats struct

+ Datafiles int

+ Keys int

+ Size int64