jobs

Documentation

Index

• Variables
• func HandleMergeEntryInTxn(txn txnif.AsyncTxn, taskName string, entry *api.MergeCommitEntry, ...) ([]*catalog.ObjectEntry, error)
• func NewFlushDeletesTask(ctx *tasks.Context, fs *objectio.ObjectFS, delta *containers.Batch, ...) *flushDeletesTask
• func NewFlushObjTask(ctx *tasks.Context, schemaVer uint32, seqnums []uint16, fs *objectio.ObjectFS, ...) *flushObjTask
• func NewFlushTableTailTask(ctx *tasks.Context, txn txnif.AsyncTxn, objs []*catalog.ObjectEntry, ...) (task *flushTableTailTask, err error)
• func NewMergeObjectsTask(ctx *tasks.Context, txn txnif.AsyncTxn, mergedObjs []*catalog.ObjectEntry, ...) (task *mergeObjectsTask, err error)
• type TestFlushBailoutPos1
• type TestFlushBailoutPos2

Variables

var (
	SlowFlushIOTask      = 10 * time.Second
	SlowFlushTaskOverall = 60 * time.Second
	SlowDelCollect       = 10 * time.Second
	SlowDelCollectNObj   = 10
)

var FlushTableTailTaskFactory = func(
	metas []*catalog.ObjectEntry, 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)
	}
}

Functions

func HandleMergeEntryInTxn

func HandleMergeEntryInTxn(
	txn txnif.AsyncTxn,
	taskName string,
	entry *api.MergeCommitEntry,
	booking api.TransferMaps,
	rt *dbutils.Runtime,
) ([]*catalog.ObjectEntry, error)

func NewFlushDeletesTask

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

func NewFlushObjTask

func NewFlushObjTask(
	ctx *tasks.Context,
	schemaVer uint32,
	seqnums []uint16,
	fs *objectio.ObjectFS,
	meta *catalog.ObjectEntry,
	data *containers.Batch,
	delta *containers.Batch,
	isAObj bool,
	parentTask string,
) *flushObjTask

func NewFlushTableTailTask

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

func NewMergeObjectsTask

func NewMergeObjectsTask(
	ctx *tasks.Context,
	txn txnif.AsyncTxn,
	mergedObjs []*catalog.ObjectEntry,
	rt *dbutils.Runtime,
	targetObjSize uint32) (task *mergeObjectsTask, err error)

Types

type TestFlushBailoutPos1

type TestFlushBailoutPos1 struct{}

type TestFlushBailoutPos2

type TestFlushBailoutPos2 struct{}