txnentries

Documentation

Index

• Constants
• func NewCompactBlockEntry(txn txnif.AsyncTxn, from, to handle.Block, sortIdx []int32, ...) *compactBlockEntry
• func NewMergeBlocksEntry(txn txnif.AsyncTxn, relation handle.Relation, ...) *mergeBlocksEntry

Constants

const (
	IOET_WALTxnCommand_Compact uint16 = 3006
	IOET_WALTxnCommand_Merge   uint16 = 3007

	IOET_WALTxnCommand_Compact_V1 uint16 = 1
	IOET_WALTxnCommand_Merge_V1   uint16 = 1

	IOET_WALTxnCommand_Compact_CurrVer = IOET_WALTxnCommand_Compact_V1
	IOET_WALTxnCommand_Merge_CurrVer   = IOET_WALTxnCommand_Merge_V1
)

Functions

func NewCompactBlockEntry

func NewCompactBlockEntry(
	txn txnif.AsyncTxn,
	from, to handle.Block,
	sortIdx []int32,
	deletes *nulls.Bitmap,
	rt *dbutils.Runtime,
) *compactBlockEntry

func NewMergeBlocksEntry

func NewMergeBlocksEntry(
	txn txnif.AsyncTxn,
	relation handle.Relation,
	droppedSegs, createdSegs []*catalog.SegmentEntry,
	droppedBlks, createdBlks []*catalog.BlockEntry,
	mapping, fromAddr, toAddr []uint32,
	deletes []*nulls.Bitmap,
	skipBlks []int,
	rt *dbutils.Runtime,
) *mergeBlocksEntry