tasks-executor-api/org.artofdev.tasks.taskExecutor

Package-level declarations

Types

CancelTaskMsg

data class CancelTaskMsg(val taskId: TaskId) : Message

ExecTaskMsg

data class ExecTaskMsg(val taskTypeHid: String, val taskId: Long, val input: TaskData?) : Message

ExecutionContext

class ExecutionContext(val taskId: Long, val taskTypeHid: String, val input: TaskData?)

IamAliveMsg

class IamAliveMsg(val taskId: TaskId?, val executorTypeHid: String, val executorHid: String? = null, val hostname: String? = null) : Message

MyArgs

class MyArgs(parser: ArgParser)

PipelineControllerEventMsg

data class PipelineControllerEventMsg(val event: PipelineControllerEvent) : Message

PipelineEndedMsg

data class PipelineEndedMsg(val taskTypeHid: String, val taskId: TaskId, val result: TaskResult) : Message

PipelineIsDoneCreatingTasksMsg

data class PipelineIsDoneCreatingTasksMsg(val pipelineTaskId: TaskId, val taskTypeHid: String? = null) : Message

TaskCancelledException

class TaskCancelledException(message: String = "Task cancelled") : RuntimeException

TaskControllerMonitorConfig

data class TaskControllerMonitorConfig(val actorsNet: ActorsNetConfig, val taskControllerActor: String, val taskControllerUrl: String, val iamAliveMsgPeriod: Int, val takeWorkAfterSlow: Int, val takeWorkAfterFast: Int, val httpRequestTimeoutMs: Long = TasksRestClient.DEFAULT_REQUEST_TIMEOUT.toMillis(), val cancelTaskTimeoutMs: Long = DEFAULT_CANCEL_TASK_TIMEOUT.toMillis())

TaskEndedMsg

data class TaskEndedMsg(val taskTypeHid: String, val taskId: Long, val output: TaskData?) : Message

TaskErrorMsg

data class TaskErrorMsg(val taskId: Long, val error: TaskError) : Message

TaskExecutor

interface TaskExecutor

TaskExecutorCli

class TaskExecutorCli(taskExecutorTypeHid: String, executorFactory: (TaskExecutorMonitorApi) -> TaskExecutor)

TaskExecutorFactory

typealias TaskExecutorFactory = (TaskExecutorMonitorApi) -> TaskExecutor

TaskExecutorMonitor

class TaskExecutorMonitor(monitorConfig: TaskControllerMonitorConfig, taskRestClientHeadersFactory: HttpHeadersFactory?, executorTypeHid: String, actorGroup: ActorIdent, executorFactory: TaskExecutorFactory, hostname: String? = localHostnameOrNull(), actorAddress: ActorIdent = makeInstanceActorAddress( actorHid = "task-executor", hostname = hostname, ), processExit: (Int) -> Unit = { exitProcess(it) }) : SimpleThreadObject, TaskExecutorMonitorBase

TaskExecutorMonitorApi

interface TaskExecutorMonitorApi

TaskExecutorMonitorBase

interface TaskExecutorMonitorBase

TaskIsPendingMsg

class TaskIsPendingMsg : Message

TaskProgressMsg

data class TaskProgressMsg(val progress: TaskProgress) : Message

TestExecutorMonitor

class TestExecutorMonitor(executorFactory: TaskExecutorFactory) : TaskExecutorMonitorApi, TaskExecutorMonitorBase

Properties

DEFAULT_CANCEL_TASK_TIMEOUT

val DEFAULT_CANCEL_TASK_TIMEOUT: Duration