jobs

Documentation

Index

• Variables
• func NewCompactBlockTask(ctx *tasks.Context, txn txnif.AsyncTxn, meta *catalog.BlockEntry, ...) (task *compactBlockTask, err error)
• func NewFlushBlkTask(ctx *tasks.Context, schemaVer uint32, seqnums []uint16, fs *objectio.ObjectFS, ...) *flushBlkTask
• func NewFlushDeletesTask(ctx *tasks.Context, fs *objectio.ObjectFS, delta *containers.Batch) *flushDeletesTask
• func NewFlushTableTailTask(ctx *tasks.Context, txn txnif.AsyncTxn, blks []*catalog.BlockEntry, ...) (task *flushTableTailTask, err error)
• func NewMergeBlocksTask(ctx *tasks.Context, txn txnif.AsyncTxn, mergedBlks []*catalog.BlockEntry, ...) (task *mergeBlocksTask, err error)
• type TestFlushBailoutPos1
• type TestFlushBailoutPos2

Variables

var CompactBlockTaskFactory = func(
	meta *catalog.BlockEntry, rt *dbutils.Runtime,
) tasks.TxnTaskFactory {
	return func(ctx *tasks.Context, txn txnif.AsyncTxn) (tasks.Task, error) {
		return NewCompactBlockTask(ctx, txn, meta, rt)
	}
}

var CompactObjectTaskFactory = func(
	mergedBlks []*catalog.BlockEntry, rt *dbutils.Runtime,
) tasks.TxnTaskFactory {
	return func(ctx *tasks.Context, txn txnif.AsyncTxn) (tasks.Task, error) {
		mergedObjs := make([]*catalog.ObjectEntry, 1)
		mergedObjs[0] = mergedBlks[0].GetObject()
		return NewMergeBlocksTask(ctx, txn, mergedBlks, mergedObjs, nil, rt)
	}
}

CompactObjectTaskFactory merge non-appendable blocks of an appendable-Object into a new non-appendable Object.

var FlushTableTailTaskFactory = func(
	metas []*catalog.BlockEntry, rt *dbutils.Runtime, endTs types.TS,
) tasks.TxnTaskFactory {
	return func(ctx *tasks.Context, txn txnif.AsyncTxn) (tasks.Task, error) {
		return NewFlushTableTailTask(ctx, txn, metas, rt, endTs)
	}
}

var MergeBlocksIntoObjectTaskFctory = func(
	mergedBlks []*catalog.BlockEntry, toObjEntry *catalog.ObjectEntry,
	rt *dbutils.Runtime,
) tasks.TxnTaskFactory {
	return func(ctx *tasks.Context, txn txnif.AsyncTxn) (tasks.Task, error) {
		return NewMergeBlocksTask(ctx, txn, mergedBlks, nil, toObjEntry, rt)
	}
}

Functions

func NewCompactBlockTask

func NewCompactBlockTask(
	ctx *tasks.Context,
	txn txnif.AsyncTxn,
	meta *catalog.BlockEntry,
	rt *dbutils.Runtime,
) (task *compactBlockTask, err error)

func NewFlushBlkTask

func NewFlushBlkTask(
	ctx *tasks.Context,
	schemaVer uint32,
	seqnums []uint16,
	fs *objectio.ObjectFS,
	meta *catalog.BlockEntry,
	data *containers.Batch,
	delta *containers.Batch,
	isABlk bool,
) *flushBlkTask

func NewFlushDeletesTask

func NewFlushDeletesTask(
	ctx *tasks.Context,
	fs *objectio.ObjectFS,
	delta *containers.Batch,
) *flushDeletesTask

func NewFlushTableTailTask

func NewFlushTableTailTask(
	ctx *tasks.Context,
	txn txnif.AsyncTxn,
	blks []*catalog.BlockEntry,
	rt *dbutils.Runtime,
	dirtyEndTs types.TS,
) (task *flushTableTailTask, err error)

func NewMergeBlocksTask

func NewMergeBlocksTask(
	ctx *tasks.Context, txn txnif.AsyncTxn,
	mergedBlks []*catalog.BlockEntry, mergedObjs []*catalog.ObjectEntry, toObjEntry *catalog.ObjectEntry,
	rt *dbutils.Runtime,
) (task *mergeBlocksTask, err error)

Types

type TestFlushBailoutPos1

type TestFlushBailoutPos1 struct{}

type TestFlushBailoutPos2

type TestFlushBailoutPos2 struct{}