txnentries

Documentation

Index

• Constants
• func NewFlushTableTailEntry(txn txnif.AsyncTxn, taskName string, mapping *api.BlkTransferBooking, ...) (*flushTableTailEntry, error)
• func NewMergeObjectsEntry(txn txnif.AsyncTxn, taskName string, relation handle.Relation, ...) (*mergeObjectsEntry, error)

Constants

const (
	IOET_WALTxnCommand_Compact        uint16 = 3006
	IOET_WALTxnCommand_Merge          uint16 = 3007
	IOET_WALTxnCommand_FlushTableTail uint16 = 3014

	IOET_WALTxnCommand_Compact_V1        uint16 = 1
	IOET_WALTxnCommand_Merge_V1          uint16 = 1
	IOET_WALTxnCommand_FlashTableTail_V1 uint16 = 1

	IOET_WALTxnCommand_Compact_CurrVer        = IOET_WALTxnCommand_Compact_V1
	IOET_WALTxnCommand_Merge_CurrVer          = IOET_WALTxnCommand_Merge_V1
	IOET_WALTxnCommand_FlushTableTail_CurrVer = IOET_WALTxnCommand_FlashTableTail_V1
)

Functions

func NewFlushTableTailEntry

func NewFlushTableTailEntry(
	txn txnif.AsyncTxn,
	taskName string,
	mapping *api.BlkTransferBooking,
	tableEntry *catalog.TableEntry,
	ablksMetas []*catalog.ObjectEntry,
	nblksMetas []*catalog.ObjectEntry,
	ablksHandles []handle.Object,
	nblksHandles []handle.Object,
	createdBlkHandles handle.Object,
	createdDeletesFile string,
	createdMergeFile string,
	dirtyLen int,
	rt *dbutils.Runtime,
	dirtyEndTs types.TS,
) (*flushTableTailEntry, error)

func NewMergeObjectsEntry

func NewMergeObjectsEntry(
	txn txnif.AsyncTxn,
	taskName string,
	relation handle.Relation,
	droppedObjs, createdObjs []*catalog.ObjectEntry,
	transMappings *api.BlkTransferBooking,
	rt *dbutils.Runtime,
) (*mergeObjectsEntry, error)