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

Package-level declarations

Types

Receives lifecycle events for one pipeline task type.

class PipelineControllerCli(pipelineControllerFactory: PipelineControllerFactory, taskControllerActorHeadersFactory: (authToken: String?) -> MessageExtraHeaders = { emptyMap() })

PipelineControllerCliArgs

class PipelineControllerCliArgs(parser: ArgParser)

PipelineControllerConfig

data class PipelineControllerConfig(val actorsNet: ActorsNetConfig, val taskControllerActor: String, val taskControllerUrl: String, val pipelineControllerActor: String, val pipelineTaskHid: String, val taskControllerAuthToken: String? = null)

PipelineControllerEvent

sealed class PipelineControllerEvent

PipelineControllerFactory

typealias PipelineControllerFactory = (PipelineControllerMonitorApi, String) -> PipelineController

PipelineControllerMonitor

class PipelineControllerMonitor(config: PipelineControllerConfig, taskRestClientHeadersFactory: HttpHeadersFactory?, taskControllerActorHeaders: MessageExtraHeaders = emptyMap(), pipelineControllerFactory: PipelineControllerFactory) : SimpleThreadObject

PipelineControllerMonitorApi

interface PipelineControllerMonitorApi

API available to pipeline controller code for creating connected tasks, reading their results, marking task creation boundaries, and finishing a pipeline.

PipelineReadyToFinish

data class PipelineReadyToFinish(val taskId: TaskId, val taskTypeHid: String, val ownerContext: OwnerContext) : PipelineControllerEvent

PipelineStarted

data class PipelineStarted(val taskId: TaskId, val taskTypeHid: String, val ownerContext: OwnerContext, val pipelineInput: TaskData?) : PipelineControllerEvent

PipelineTaskFinished

data class PipelineTaskFinished(val taskId: TaskId, val taskTypeHid: String, val pipelineTaskId: TaskId, val pipelineOwnerContext: OwnerContext, val taskResult: TaskResult) : PipelineControllerEvent

PipelineTaskTypeFinished

data class PipelineTaskTypeFinished(val pipelineTaskId: TaskId, val taskTypeHid: String) : PipelineControllerEvent

Functions

pipelineControllerGroupAddress

fun pipelineControllerGroupAddress(pipelineTaskHid: String): ActorIdent