jobs

Documentation

Index

• Variables
• func NewCompactBlockTask(ctx *tasks.Context, txn txnif.AsyncTxn, meta *catalog.BlockEntry, ...) (task *compactBlockTask, err error)
• func NewDelSegTask(ctx *tasks.Context, txn txnif.AsyncTxn, delSegs []*catalog.SegmentEntry) *delSegTask
• 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)

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 CompactSegmentTaskFactory = func(
	mergedBlks []*catalog.BlockEntry, rt *dbutils.Runtime,
) tasks.TxnTaskFactory {
	return func(ctx *tasks.Context, txn txnif.AsyncTxn) (tasks.Task, error) {
		mergedSegs := make([]*catalog.SegmentEntry, 1)
		mergedSegs[0] = mergedBlks[0].GetSegment()
		return NewMergeBlocksTask(ctx, txn, mergedBlks, mergedSegs, nil, rt)
	}
}

CompactSegmentTaskFactory merge non-appendable blocks of an appendable-segment into a new non-appendable segment.

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 MergeBlocksIntoSegmentTaskFctory = func(
	mergedBlks []*catalog.BlockEntry, toSegEntry *catalog.SegmentEntry,
	rt *dbutils.Runtime,
) tasks.TxnTaskFactory {
	return func(ctx *tasks.Context, txn txnif.AsyncTxn) (tasks.Task, error) {
		return NewMergeBlocksTask(ctx, txn, mergedBlks, nil, toSegEntry, rt)
	}
}

Functions

func NewCompactBlockTask

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

func NewDelSegTask

func NewDelSegTask(ctx *tasks.Context, txn txnif.AsyncTxn, delSegs []*catalog.SegmentEntry) *delSegTask

func NewFlushBlkTask

func NewFlushBlkTask(
	ctx *tasks.Context,
	schemaVer uint32,
	seqnums []uint16,
	fs *objectio.ObjectFS,
	meta *catalog.BlockEntry,
	data *containers.Batch,
	delta *containers.Batch,
) *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, mergedSegs []*catalog.SegmentEntry, toSegEntry *catalog.SegmentEntry,
	rt *dbutils.Runtime,
) (task *mergeBlocksTask, err error)