Versions in this module Expand all Collapse all v0 v0.8.0 Apr 8, 2026 v0.7.0 Mar 14, 2026 v0.6.0 Feb 15, 2026 v0.5.6 Feb 14, 2026 v0.5.5 Feb 14, 2026 v0.5.4 Feb 14, 2026 Changes in this version + const CurrentFormatVersion + const DefaultPageSize + const InvalidPageID + const MaxPageSize + const MinPageSize + const OverflowThreshold + const PageHeaderSize + const SuperblockMagic + const WALFileHdrSize + const WALMagic + const WALRecHdrSize + const WALVersion + func ComputePageCRC(page []byte) uint32 + func DumpTree(dbPath string, rootPageID PageID, pageSize int) (string, error) + func FreeListCapacity(pageSize int) int + func MarshalHeader(h *PageHeader, buf []byte) + func MarshalRow(row []any, buf []byte) []byte + func MarshalSuperblock(sb *Superblock, pageSize int) []byte + func NewPage(pageSize int, pt PageType, id PageID) []byte + func OverflowCapacity(pageSize int) int + func ParseRowKey(key []byte) int64 + func RowKey(rowID int64) []byte + func SetPageCRC(page []byte) + func UnmarshalRow(data []byte) ([]any, error) + func VerifyDB(dbPath string) ([]string, error) + func VerifyPageCRC(page []byte) error + type BTree struct + func CreateBTree(p *Pager, txID TxID) (*BTree, error) + func NewBTree(p *Pager, root PageID) *BTree + func (bt *BTree) Count() (int, error) + func (bt *BTree) Delete(txID TxID, key []byte) (bool, error) + func (bt *BTree) FreeAllPages() + func (bt *BTree) Get(key []byte) ([]byte, bool, error) + func (bt *BTree) Insert(txID TxID, key, value []byte) error + func (bt *BTree) Root() PageID + func (bt *BTree) ScanRange(startKey, endKey []byte, fn func(key, value []byte) bool) error + type BTreePage struct + func InitBTreePage(buf []byte, id PageID, leaf bool) *BTreePage + func WrapBTreePage(buf []byte) *BTreePage + func (bp *BTreePage) Bytes() []byte + func (bp *BTreePage) DeleteLeafEntry(pos int) error + func (bp *BTreePage) FindChild(key []byte) PageID + func (bp *BTreePage) FindLeafEntry(key []byte) (int, bool) + func (bp *BTreePage) GetAllInternalEntries() []InternalEntry + func (bp *BTreePage) GetAllLeafEntries() []LeafEntry + func (bp *BTreePage) GetInternalEntry(i int) InternalEntry + func (bp *BTreePage) GetLeafEntry(i int) LeafEntry + func (bp *BTreePage) InsertInternalEntry(entry InternalEntry) error + func (bp *BTreePage) InsertLeafEntry(entry LeafEntry) (int, error) + func (bp *BTreePage) IsLeaf() bool + func (bp *BTreePage) KeyCount() int + func (bp *BTreePage) NextLeaf() PageID + func (bp *BTreePage) PageID() PageID + func (bp *BTreePage) PrevLeaf() PageID + func (bp *BTreePage) RightChild() PageID + func (bp *BTreePage) SearchInternal(key []byte) PageID + func (bp *BTreePage) SetNextLeaf(pid PageID) + func (bp *BTreePage) SetPrevLeaf(pid PageID) + func (bp *BTreePage) SetRightChild(pid PageID) + func (bp *BTreePage) UpdateLeafEntry(pos int, entry LeafEntry) error + type BufferPoolConfig struct + MaxPages int + type Catalog struct + func OpenCatalog(p *Pager, txID TxID) (*Catalog, error) + func (c *Catalog) DeleteEntry(txID TxID, tenant, table string) error + func (c *Catalog) GetEntry(tenant, table string) (*CatalogEntry, error) + func (c *Catalog) ListTables(tenant string) ([]string, error) + func (c *Catalog) PutEntry(txID TxID, entry CatalogEntry) error + func (c *Catalog) Root() PageID + type CatalogColumn struct + Constraint int + FKColumn string + FKTable string + Name string + PtrTable string + Type int + type CatalogEntry struct + Columns []CatalogColumn + RootPageID PageID + RowCount int64 + Table string + Tenant string + Version int + type ColumnInfo struct + Constraint int + FKColumn string + FKTable string + Name string + PointerTable string + Type int + type FeatureFlag uint64 + const FeatureCompression + const FeatureEncryption + const FeatureMVCC + const FeaturePartitions + const SupportedFeatures + type FreeListPage struct + func InitFreeListPage(buf []byte, id PageID) *FreeListPage + func WrapFreeListPage(buf []byte) *FreeListPage + func (fl *FreeListPage) AddEntry(pid PageID) bool + func (fl *FreeListPage) AllEntries() []PageID + func (fl *FreeListPage) Bytes() []byte + func (fl *FreeListPage) EntryCount() int + func (fl *FreeListPage) GetEntry(i int) PageID + func (fl *FreeListPage) NextFreeList() PageID + func (fl *FreeListPage) PopEntry() PageID + func (fl *FreeListPage) SetNextFreeList(pid PageID) + type FreeManager struct + func NewFreeManager() *FreeManager + func (fm *FreeManager) AllFree() []PageID + func (fm *FreeManager) Alloc() PageID + func (fm *FreeManager) Count() int + func (fm *FreeManager) FlushToDisk(pageSize int, allocPage func() (PageID, []byte)) (PageID, [][]byte) + func (fm *FreeManager) Free(pid PageID) + func (fm *FreeManager) LoadFromDisk(head PageID, readPage func(PageID) ([]byte, error)) error + type GCResult struct + Errors []string + FreeAfter int + FreeBefore int + ReachablePages int + Reclaimed int + TotalPages int + type InternalEntry struct + ChildID PageID + Key []byte + type LSN uint64 + type LeafEntry struct + Key []byte + Overflow bool + OverflowPageID PageID + TotalSize uint32 + Value []byte + type OverflowPage struct + func InitOverflowPage(buf []byte, id PageID) *OverflowPage + func WrapOverflowPage(buf []byte) *OverflowPage + func (op *OverflowPage) Bytes() []byte + func (op *OverflowPage) Data() []byte + func (op *OverflowPage) DataLen() int + func (op *OverflowPage) NextOverflow() PageID + func (op *OverflowPage) SetData(data []byte) error + func (op *OverflowPage) SetNextOverflow(pid PageID) + type PageBackend struct + func NewPageBackend(cfg PageBackendConfig) (*PageBackend, error) + func (pb *PageBackend) Close() error + func (pb *PageBackend) DBPath() string + func (pb *PageBackend) DeleteTable(tenant, name string) error + func (pb *PageBackend) GC() (*GCResult, error) + func (pb *PageBackend) ListTableNames(tenant string) ([]string, error) + func (pb *PageBackend) LoadTable(tenant, name string) (*TableData, error) + func (pb *PageBackend) Pager() *Pager + func (pb *PageBackend) SaveTable(tenant string, td *TableData) error + func (pb *PageBackend) Stats() PageBackendStats + func (pb *PageBackend) Sync() error + func (pb *PageBackend) TableExists(tenant, name string) bool + type PageBackendConfig struct + MaxCachePages int + PageSize int + Path string + type PageBackendStats struct + CheckpointLSN LSN + DBPath string + FreePages int + LoadCount int64 + NextTxID TxID + PageCount uint64 + PageSize int + SyncCount int64 + WALPath string + type PageBufferPool struct + type PageFrame struct + type PageHeader struct + CRC uint32 + Flags uint8 + ID PageID + LSN LSN + Pad [12]byte + Reserved uint16 + Type PageType + func UnmarshalHeader(buf []byte) PageHeader + type PageID uint32 + type PageInfo struct + CRC uint32 + CRCValid bool + DataLen int + EntryCount int + Flags uint8 + FreeSpace int + ID PageID + IsLeaf bool + KeyCount int + LSN LSN + NextFreeList PageID + NextLeaf PageID + NextOverflow PageID + PrevLeaf PageID + RightChild PageID + SlotCount int + Type PageType + TypeStr string + func InspectPage(dbPath string, pageID PageID, pageSize int) (*PageInfo, error) + type PageType uint8 + const PageTypeBTreeInternal + const PageTypeBTreeLeaf + const PageTypeFreeList + const PageTypeOverflow + const PageTypeSuperblock + func (pt PageType) String() string + type Pager struct + func OpenPager(cfg PagerConfig) (*Pager, error) + func (p *Pager) AbortTx(txID TxID) error + func (p *Pager) AllocPage() (PageID, []byte) + func (p *Pager) BeginTx() (TxID, error) + func (p *Pager) Checkpoint() error + func (p *Pager) Close() error + func (p *Pager) CommitTx(txID TxID) error + func (p *Pager) FreePage(pid PageID) + func (p *Pager) PageSize() int + func (p *Pager) Path() string + func (p *Pager) ReadPage(id PageID) ([]byte, error) + func (p *Pager) Recover() error + func (p *Pager) Superblock() Superblock + func (p *Pager) UnpinPage(id PageID) + func (p *Pager) UpdateSuperblock(fn func(sb *Superblock)) + func (p *Pager) WALPath() string + func (p *Pager) WritePage(txID TxID, id PageID, buf []byte) error + type PagerConfig struct + DBPath string + MaxCachePages int + PageSize int + WALPath string + type SlotEntry struct + Length uint16 + Offset uint16 + type SlottedPage struct + func InitSlottedPage(buf []byte, pt PageType, id PageID) *SlottedPage + func WrapSlottedPage(buf []byte) *SlottedPage + func (sp *SlottedPage) Bytes() []byte + func (sp *SlottedPage) Compact() + func (sp *SlottedPage) DeleteRecord(i int) error + func (sp *SlottedPage) FreeSpace() int + func (sp *SlottedPage) FreeSpaceEnd() int + func (sp *SlottedPage) GetRecord(i int) []byte + func (sp *SlottedPage) GetSlot(i int) SlotEntry + func (sp *SlottedPage) InsertRecord(data []byte) (int, error) + func (sp *SlottedPage) IsDeleted(i int) bool + func (sp *SlottedPage) LiveRecords() int + func (sp *SlottedPage) SlotCount() int + func (sp *SlottedPage) UpdateRecord(i int, data []byte) error + type Superblock struct + CatalogRoot PageID + CheckpointLSN LSN + FeatureFlags FeatureFlag + FormatVersion uint32 + FreeListRoot PageID + NextPageID PageID + NextTxID TxID + PageCount uint64 + PageSize uint32 + func NewSuperblock(pageSize uint32) *Superblock + func UnmarshalSuperblock(buf []byte) (*Superblock, error) + type SuperblockInfo struct + CRCValid bool + CatalogRoot PageID + CheckpointLSN LSN + FeatureFlags uint64 + FormatVersion uint32 + FreeListRoot PageID + NextPageID PageID + NextTxID TxID + PageCount uint64 + PageSize uint32 + func InspectSuperblock(dbPath string) (*SuperblockInfo, error) + type TableData struct + Columns []ColumnInfo + IsTemp bool + Name string + Rows [][]any + Version int + type TxID uint64 + type WALFile struct + func OpenWALFile(path string, pageSize int) (*WALFile, error) + func (wf *WALFile) AppendRecord(rec *WALRecord) (LSN, error) + func (wf *WALFile) Close() error + func (wf *WALFile) NextLSN() LSN + func (wf *WALFile) SetNextLSN(lsn LSN) + func (wf *WALFile) Sync() error + func (wf *WALFile) Truncate() error + type WALInfo struct + Aborted int + Committed int + MaxLSN LSN + MinLSN LSN + PageImages int + PageSize int + Records int + TxCount int + func InspectWAL(walPath string) (*WALInfo, error) + type WALRecord struct + Data []byte + LSN LSN + PageID PageID + TxID TxID + Type WALRecordType + func ReadAllRecords(path string) ([]*WALRecord, error) + type WALRecordType uint8 + const WALRecordAbort + const WALRecordBegin + const WALRecordCheckpoint + const WALRecordCommit + const WALRecordPageImage + func (rt WALRecordType) String() string
Go to main page