DebugCtlTaskFramework disable task framework.

NewFixedTaskStorageFactory creates a fixed task storage factory which always returns the special taskstorage.

NewTaskRunner new task runner.

NewTaskService create a task service based on a task storage.

NewTaskServiceHolder create a task service hold, it will create task storage and task service from the hakeeper's schedule command.

NewTaskServiceHolderWithTaskStorageFactorySelector is similar to NewTaskServiceHolder, but with a special task storage facroty selector.

WithAccount set task account condition.

WithAccountID set task account ID condition.

WithLastHeartbeat set last heartbeat condition.

WithLimitCond set query result limit.

WithOptions set all options needed by taskRunner.

WithRunnerFetchInterval set fetch tasks interval duration.

WithRunnerFetchLimit set fetch tasks limit.

WithRunnerFetchTimeout set fetch timeout.

WithRunnerHeartbeatInterval set heartbeat duration.

WithRunnerHeartbeatTimeout set heartbeat timeout.

WithRunnerLogger set logger.

WithRunnerMaxWaitTasks set the maximum number of tasks waiting to be executed, more than that will block fetching tasks.

WithRunnerParallelism set the parallelism for execute tasks.

WithRunnerRetryInterval set retry interval duration for operation.

WithTaskEpochCond set task epoch condition.

WithTaskExecutorCond set task executor condition.

WithTaskIDCond set task id condition.

WithTaskIDDesc set query with order by task id desc.

WithTaskParentTaskIDCond set task ParentTaskID condition.

WithTaskRunnerCond set task runner condition.

WithTaskStatusCond set status condition.

WithTaskType set task type condition.

EQ record == condition.

GE record >= condition.

GT record > condition.

IN record in condition.

LE record <= condition.

LIKE record LIKE condition.

LT record < condition.

ActiveRoutine is an interface that the go routine of the daemon task should implement.

TaskRunner each runner can execute multiple task concurrently.

TaskService Asynchronous Task Service, which provides scheduling execution and management of asynchronous tasks.

TaskServiceHolder create and hold the task service in the cn, tn and log node.

TaskStorage task storage.

Condition options for query tasks.

Op condition op.

RunnerOption option for create task runner.

TaskExecutor which is responsible for the execution logic of a specific Task, and the function exists to represent the completion of the task execution.