shs

Oct 16, 2024

Changes in this version

type DefaultIndex

+ func NewDefaultIndex() *DefaultIndex

+ type RBTreeIndex rbtree.RbTree[string, uint64]

+ func NewRBTreeIndex() *RBTreeIndex

+ func (R *RBTreeIndex) Delete(key []byte) error

+ func (R *RBTreeIndex) Get(key []byte) (uint64, error)

+ func (R *RBTreeIndex) Iterator() iter.Seq2[[]byte, uint64]

+ func (R *RBTreeIndex) Set(key []byte, value uint64) error

+ type SkipListIndex skiplist.Skiplist[string, uint64]

+ func NewSkipListIndex() *SkipListIndex

+ func (s *SkipListIndex) Delete(key []byte) error

+ func (s *SkipListIndex) Get(key []byte) (uint64, error)

+ func (s *SkipListIndex) Iterator() iter.Seq2[[]byte, uint64]

+ func (s *SkipListIndex) Set(key []byte, value uint64) error

Oct 16, 2024

Changes in this version

+ type BTreeIndex btree.Map[string, uint64]

+ func NewBTreeIndex() *BTreeIndex

+ func (B *BTreeIndex) Delete(key []byte) error

+ func (B *BTreeIndex) Get(key []byte) (uint64, error)

+ func (B *BTreeIndex) Iterator() iter.Seq2[[]byte, uint64]

+ func (B *BTreeIndex) Set(key []byte, value uint64) error

Oct 16, 2024

Changes in this version

+ type SortUserRecordByKey []Record

+ func (s SortUserRecordByKey) Len() int

+ func (s SortUserRecordByKey) Less(i, j int) bool

+ func (s SortUserRecordByKey) Swap(i, j int)

Oct 15, 2024

Changes in this version

+ var ErrKeyEmpty = fmt.Errorf("key cannot be empty")

+ var ErrKeyNotFound = fmt.Errorf("key not found")

+ var ErrRecordTooLarge = fmt.Errorf("key or value is too large, the size cannot exceed 4056")

Oct 15, 2024

Changes in this version

+ const FileTrailerSize

+ const PageHeaderSize

+ const PageSize

+ type DataPage struct

+ FileTrailer [8]byte

+ PageID uint64

+ UserRecords []Record

+ UserRecordsSize uint64

+ type DefaultIndex struct

+ func (d *DefaultIndex) Delete(key []byte) error

+ func (d *DefaultIndex) Get(key []byte) (uint64, error)

+ func (d *DefaultIndex) Iterator() iter.Seq2[[]byte, uint64]

+ func (d *DefaultIndex) Set(key []byte, value uint64) error

+ type Index interface

+ Delete func(key []byte) error

+ Get func(key []byte) (uint64, error)

+ Iterator func() iter.Seq2[[]byte, uint64]

+ Set func(key []byte, value uint64) error

+ type Options struct

+ DataIndex Index

+ DirPath string

+ type Record struct

+ Key []byte

+ Value []byte

+ type StorageEngine struct

+ func NewStorageEngine(opt Options) (*StorageEngine, error)

+ func (se *StorageEngine) Close() error

+ func (se *StorageEngine) Delete(key []byte) error

+ func (se *StorageEngine) Get(key []byte) ([]byte, error)

+ func (se *StorageEngine) Insert(key, value []byte) error

+ func (se *StorageEngine) Modify(key, value []byte) error

+ type WalRecord struct

+ Key []byte

+ PageID uint64

+ Type WalRecordType

+ type WalRecordType uint8

+ const WalOpDelete

+ const WalOpInsert