jobs

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)
	}
}

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)
	}
}