storage

type Blob ¶

type Blob struct {
	Kind  uint8
	Class BlobClass
	Data  []byte
}

type BlobClass ¶

type BlobClass uint8

const (
	BlobClassRecord BlobClass = iota
	BlobClassIndex
)

type File ¶

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

func (f *File) Checkpoint(token uint64, snapshot []byte) error

func (f *File) CheckpointBlobs(token uint64, blobs []Blob) error

func (f *File) Close() error

type Meta ¶

type Meta struct {
	DatabaseID      [16]byte
	Generation      uint64
	RootPage        uint64
	PageCount       uint32
	CheckpointToken uint64
}

type OpenOptions ¶

type OpenOptions struct{ RequireClean bool }

type OpenReport ¶

type OpenReport struct {
	Created                bool
	SelectedMetaSlot       uint8
	ValidMetaSlots         uint8
	MetaRedundancyDegraded bool
	TrailingBytesRemoved   uint64
	FreePageReuseDegraded  bool
}

OpenReport records bounded recovery actions performed by OpenBlobsWithReport. It deliberately excludes paths and snapshot contents.

type RecordID ¶

type RecordID struct {
	Page       uint64
	Slot       uint16
	Generation uint32
}

RecordID never aliases a reused slot: deleting a record advances the slot's generation before that slot can be allocated again.

type RecordPage ¶

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

RecordPage is a slotted 16 KiB document page. Its binary form packs record bodies from the header upward and the fixed-size slot directory downward.

func DecodeIndexPage(page []byte, expectedPageID uint64) (*RecordPage, error)

func DecodeRecordPage(page []byte, expectedPageID uint64) (*RecordPage, error)

func NewIndexPageAt(pageID, generation, lsn uint64) *RecordPage

func NewRecordPage(pageID uint64) *RecordPage

func NewRecordPageAt(pageID, generation, lsn uint64) *RecordPage

func (p *RecordPage) Delete(id RecordID) error

func (p *RecordPage) FreeBytes() int

func (p *RecordPage) Generation() uint64

func (p *RecordPage) Get(id RecordID) ([]byte, error)

func (p *RecordPage) Insert(record []byte) (RecordID, error)

func (p *RecordPage) LSN() uint64

func (p *RecordPage) MarshalBinary() ([]byte, error)

func (p *RecordPage) PageID() uint64

func (p *RecordPage) Update(id RecordID, record []byte) error