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

Package-level declarations

Types

ExecTaskMsg

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

ExecutionContext

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

IamAliveMsg

class IamAliveMsg(val taskId: TaskId?, val executorTypeHid: String) : Message

MonitorConfig

data class MonitorConfig(val actorsNet: ActorsNetConfig, val taskControllerActor: String, val taskControllerUrl: String, val iamAliveMsgPeriod: Int, val takeWorkAfterSlow: Int, val takeWorkAfterFast: Int)

MyArgs

class MyArgs(parser: ArgParser)

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: MonitorConfig, taskRestClientHeadersFactory: HttpHeadersFactory?, executorTypeHid: String, actorGroup: ActorIdent, actorAddress: ActorIdent, val executorFactory: TaskExecutorFactory) : SimpleThreadObject, TaskExecutorMonitorBase

TaskExecutorMonitorApi

interface TaskExecutorMonitorApi

TaskExecutorMonitorBase

interface TaskExecutorMonitorBase

TaskIsPendingMsg

class TaskIsPendingMsg : Message

TaskProgressMsg

data class TaskProgressMsg(val progress: TaskProgress) : Message

TestExecutorMonitor

class TestExecutorMonitor(val executorFactory: TaskExecutorFactory) : TaskExecutorMonitorApi, TaskExecutorMonitorBase