tasks

type BaseDispatcher struct {
	// contains filtered or unexported fields
}

type BaseScheduler struct {
	ops.OpWorker

	Dispatchers map[TaskType]Dispatcher
	// contains filtered or unexported fields
}

type BaseScopedDispatcher struct {
	// contains filtered or unexported fields
}

type BaseTask struct {
	ops.Op
	// contains filtered or unexported fields
}

type BaseTaskHandler struct {
	ops.OpWorker
}

type Context struct {
	DoneCB   ops.OpDoneCB
	Waitable bool
}

type Dispatcher interface {
	io.Closer
	Dispatch(Task)
}

type FnTask struct {
	*BaseTask
	Fn FuncT
}

type FuncT = func() error

type Job struct {
	// contains filtered or unexported fields
}

type JobExecutor = func(context.Context) *JobResult

type JobResult struct {
	Err error
	Res any
}

type JobScheduler interface {
	Schedule(job *Job) error
	Stop()
}

type MScopedTask interface {
	Task
	Scopes() []common.ID
}

type MultiScopedFnTask struct {
	*FnTask
	// contains filtered or unexported fields
}

type Scheduler interface {
	Start()
	Stop()
	Schedule(Task) error
}

type ScopedFnTask struct {
	*FnTask
	// contains filtered or unexported fields
}

type ScopedTask interface {
	Task
	Scope() *common.ID
}

type ScopedTaskSharder = func(scope *common.ID) int

type Task interface {
	base.IOp
	ID() uint64
	Type() TaskType
	Cancel() error
	Name() string
}

type TaskHandler interface {
	io.Closer
	Start()
	Enqueue(Task)
	Execute(Task)
}

type TaskScheduler interface {
	Scheduler
	ScheduleTxnTask(ctx *Context, taskType TaskType, factory TxnTaskFactory) (Task, error)
	ScheduleMultiScopedTxnTask(ctx *Context, taskType TaskType, scopes []common.ID, factory TxnTaskFactory) (Task, error)
	ScheduleMultiScopedFn(ctx *Context, taskType TaskType, scopes []common.ID, fn FuncT) (Task, error)
	ScheduleFn(ctx *Context, taskType TaskType, fn func() error) (Task, error)
	ScheduleScopedFn(ctx *Context, taskType TaskType, scope *common.ID, fn func() error) (Task, error)
	Checkpoint(indexes []*wal.Index) error

	AddTransferPage(*model.TransferHashPage) error
	DeleteTransferPage(id *common.ID) error

	GetCheckpointedLSN() uint64
	GetPenddingLSNCnt() uint64
	GetGCTS() types.TS
	GetCheckpointTS() types.TS
}

type TaskType uint16

type TxnTaskFactory = func(ctx *Context, txn txnif.AsyncTxn) (Task, error)