bitcask

package

v0.0.0-...-bda965e Latest Latest Go to latest Published: Feb 29, 2020 License: MIT Imports: 10 Imported by: 0

Details

View Source

const (
	//default file size 1G
	DefaultMaxFileSize  = (1 << 32) - 1
	DefaultMaxValueSize = (1 << 8) - 1
	DefaultFileDir      = "data"
)

View Source

const (

	// 4*4
	ItemSizeWithoutKV = 1 << 4

	// 4*3 + 8 =20
	HintSizeWithoutK = 20
)

View Source

var (
	ErrNotFound = errors.New("Not Found ")

	ErrCRC32 = errors.New("Checksum IEEE error ")

	ErrReadFailed = errors.New("Read BitCask Failed ")
)

func DecodeItem(buf []byte) ([]byte, error)

type BitCask struct {
	// contains filtered or unexported fields
}

func Open(cfg *Config) (*BitCask, error)

func (bc *BitCask) Close()

func (bc *BitCask) Del(key []byte) error

func (bc *BitCask) Get(key []byte) ([]byte, error)

func (bc *BitCask) Put(key []byte, value []byte) error

func (bc *BitCask) Sync()

type Config struct {
	MaxFileSize  uint64
	MaxValueSize uint64
	FileDir      string
}

type File struct {
	Offset uint64
	// contains filtered or unexported fields
}

func NewFile() *File

func OpenFile(fileDir string, fileId int) (*File, error)

func (af *File) CloseAll()

func (af *File) Delete(key []byte) error

func (af *File) GetFileId() uint32

func (af *File) GetFileOffset() uint64

func (af *File) Read(off uint64, dataLen uint32) ([]byte, error)

根据offset在文件中获取，并返回数据

func (af *File) Sync()

func (af *File) Write(key []byte, value []byte) (fileItem, error)

type Files struct {
	// contains filtered or unexported fields
}

只读文件

func (fs *Files) CloseAllFile()

func (fs *Files) GetFilePtr(fileId uint32) *File

func (fs *Files) PutFilePtr(f *File, fileId uint32)

type HashTable struct {
	// contains filtered or unexported fields
}

type MultiFileReader interface {
	GetFilePtr(uint32) *File
	PutFilePtr(*File, uint32)
	CloseAllFile()
}