mutcask

Feb 11, 2023

Changes in this version

+ const MAX_PARALLEL_READ

type Config

+ MaxParallelRead int

type Option

+ func MaxParallelReadConf(n int) Option

Jan 5, 2023

Changes in this version

+ var ErrNoSupport = xerrors.New("mutcask: method not support")

type KVDB

+ Read func(string, io.Writer) (int, error)

Dec 10, 2022

Changes in this version

type Config

+ MaxLogFileSize int

Aug 18, 2022

Changes in this version

+ func NewCachedMutcask(cache_num int, opts ...Option) (*cachedMutcask, error)

Aug 15, 2022

Changes in this version

type Config

+ Migrate bool

+ type HintLV struct

+ VOffset uint64

+ VSize uint32

+ func HintLVFromBytes(b []byte) (h *HintLV, err error)

+ func (h *HintLV) Bytes() (ret []byte, err error)

type Option

+ func MigrateConf() Option

Aug 8, 2022

Changes in this version

+ const SLICE_SCALE

+ const VBUF_1M

+ const VBUF_4M

+ func NewLevedbKV(dir string) (*levedbKV, error)

type Config

+ InitBuf int

type Hint

+ func (h *Hint) Less(than btree.Item) bool

type KVDB

+ CheckSum func(string) (string, error)

type Option

+ func InitBufConf(size int) Option

May 17, 2022

Changes in this version

type KVDB

+ func NewMemkv() KVDB

Apr 24, 2022

Changes in this version

+ const HintDeletedFlag

+ const HintEncodeSize

+ const HintKeySize

+ const MaxKeySize

+ var ErrDataRotted = xerrors.New("mutcask: data may be rotted")

+ var ErrHintFormat = xerrors.New("mutcask: invalid hint format")

+ var ErrHintLogBroken = xerrors.New("mutcask: hint log broken")

+ var ErrKeySizeTooLong = xerrors.New("mutcask: key size is too long")

+ var ErrNone = xerrors.New("mutcask: error none")

+ var ErrNotFound = xerrors.New("kv: key not found")

+ var ErrPath = xerrors.New("mutcask: path should be directory not file")

+ var ErrPathUndefined = xerrors.New("mutcask: should define path within config")

+ var ErrReadHintBeyondRange = xerrors.New("mutcask: read hint out of file range")

+ var ErrRepoLocked = xerrors.New("mutcask: repo has been locked")

+ var ErrValueFormat = xerrors.New("mutcask: invalid value format")

+ func DecodeValue(buf []byte, verify bool) (v []byte, err error)

+ func EncodeValue(v []byte) (ret []byte)

+ func NewMutcask(opts ...Option) (*mutcask, error)

+ type Cask struct

+ func NewCask(id uint32) *Cask

+ func (c *Cask) Close()

+ func (c *Cask) Delete(key string) (err error)

+ func (c *Cask) Put(key string, value []byte) (err error)

+ func (c *Cask) Read(key string) (v []byte, err error)

+ func (c *Cask) Size(key string) (int, error)

+ type CaskMap struct

+ func (cm *CaskMap) Add(id uint32, cask *Cask)

+ func (cm *CaskMap) CloseAll()

+ func (cm *CaskMap) Get(id uint32) (c *Cask, b bool)

+ type Config struct

+ CaskNum uint32

+ HintBootReadNum int

+ Path string

+ type Hint struct

+ Deleted bool

+ KOffset uint64

+ Key string

+ VOffset uint64

+ VSize uint32

+ func (h *Hint) Encode() (ret []byte, err error)

+ func (h *Hint) From(buf []byte) (err error)

+ type KVDB interface

+ AllKeysChan func(context.Context) (chan string, error)

+ Close func() error

+ Delete func(string) error

+ Get func(string) ([]byte, error)

+ Put func(string, []byte) error

+ Size func(string) (int, error)

+ type KeyMap struct

+ func (km *KeyMap) Add(key string, hint *Hint)

+ func (km *KeyMap) Get(key string) (h *Hint, b bool)

+ type Option func(cfg *Config)

+ func CaskNumConf(caskNum int) Option

+ func HintBootReadNumConf(hn int) Option

+ func PathConf(dir string) Option