txnentries

Documentation

Index

• Constants
• func NewCompactBlockEntry(txn txnif.AsyncTxn, from, to handle.Block, scheduler tasks.TaskScheduler, ...) *compactBlockEntry
• func NewMergeBlocksEntry(txn txnif.AsyncTxn, relation handle.Relation, ...) *mergeBlocksEntry
• func ReadBlkID(r io.Reader, id *common.ID) (n int64, err error)
• func ReadSegID(r io.Reader, id *common.ID) (n int64, err error)
• func ReadUint32Array(r io.Reader) (array []uint32, n int64, err error)
• func WriteBlkID(w io.Writer, id *common.ID) (n int64, err error)
• func WriteSegID(w io.Writer, id *common.ID) (n int64, err error)
• func WriteUint32Array(w io.Writer, array []uint32) (n int64, err error)

Constants

const (
	CmdCompactBlock int16 = 0x0200 + iota
	CmdMergeBlocks
)

Functions

func NewCompactBlockEntry

func NewCompactBlockEntry(
	txn txnif.AsyncTxn,
	from, to handle.Block,
	scheduler tasks.TaskScheduler,
	sortIdx []uint32,
	deletes *roaring.Bitmap) *compactBlockEntry

func NewMergeBlocksEntry

func NewMergeBlocksEntry(
	txn txnif.AsyncTxn,
	relation handle.Relation,
	droppedSegs, createdSegs []*catalog.SegmentEntry,
	droppedBlks, createdBlks []*catalog.BlockEntry,
	mapping, fromAddr, toAddr []uint32,
	deletes []*roaring.Bitmap,
	skipBlks []int,
	scheduler tasks.TaskScheduler) *mergeBlocksEntry

func ReadBlkID

func ReadBlkID(r io.Reader, id *common.ID) (n int64, err error)

func ReadSegID

func ReadSegID(r io.Reader, id *common.ID) (n int64, err error)

func ReadUint32Array

func ReadUint32Array(r io.Reader) (array []uint32, n int64, err error)

func WriteBlkID

func WriteBlkID(w io.Writer, id *common.ID) (n int64, err error)

func WriteSegID

func WriteSegID(w io.Writer, id *common.ID) (n int64, err error)

func WriteUint32Array

func WriteUint32Array(w io.Writer, array []uint32) (n int64, err error)