txnentries

package
v1.2.2-20240715 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jul 15, 2024 License: Apache-2.0 Imports: 23 Imported by: 0

Documentation

Index

Constants

View Source
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
)

Variables

This section is empty.

Functions

func NewFlushTableTailEntry added in v1.0.0

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 added in v1.2.0

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

Types

This section is empty.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL