tasks-controller/org.artofdev.tasks.controller

Package-level declarations

Types

BuildInfoLogger

@Component

class BuildInfoLogger

ExecutionEngine

interface ExecutionEngine

JacksonUtils

object JacksonUtils

KubernetesExecutionEngine

@Service

@ConditionalOnProperty(prefix = "tasks.controller.kb-engine", name = ["enabled"], havingValue = "true")

class KubernetesExecutionEngine(config: TaskControllerConfig, kbConfig: KubernetesExecutionConfig, executorTypeRepo: TaskExecutorTypeRepo, tasksActorApi: TasksActorApi) : ExecutionEngine

NotAuthorisedException

@ResponseStatus(value = HttpStatus.FORBIDDEN)

class NotAuthorisedException : RuntimeException

PluginManager

class PluginManager(val pluginsConfig: PluginsConfig)

PluginManagerError

class PluginManagerError(message: String, val pluginDir: String? = null) : Exception

PluginManagerService

@Service

class PluginManagerService(config: TaskControllerConfig)

ProductionConfiguration

@Configuration

@Profile(value = ["production", "integration-tests"])

class ProductionConfiguration(config: TaskControllerConfig, kbConfig: KubernetesExecutionConfig?)

RecoverableMessageError

class RecoverableMessageError(message: String) : RuntimeException

TaskControllerApp

@SpringBootApplication(scanBasePackages = ["org.artofdev.tasks.controller"])

@ConfigurationPropertiesScan

class TaskControllerApp

TasksActor

@Service

class TasksActor(config: TaskControllerConfig, actorNet: IActorNet, taskRepo: TaskRepo, taskTypeRepo: TaskTypeRepo, pipelineTaskTypeRepo: PipelineTaskTypeRepo, errorRepo: ErrorRepo, transactionTemplate: TransactionTemplate, var executorRepo: ExecutorRepo, pluginManagerService: PluginManagerService, @Lazy taskServiceApi: TaskServiceApi, var executorTypeRepo: TaskExecutorTypeRepo, executionEngine: ExecutionEngine? = null) : SimpleThreadObject, TasksActorApi, TaskServiceBase

TasksActorApi

interface TasksActorApi

TaskService

@Service

class TaskService(config: TaskControllerConfig, transactionTemplate: TransactionTemplate, taskRepo: TaskRepo, taskTypeRepo: TaskTypeRepo, pipelineTaskTypeRepo: PipelineTaskTypeRepo, errorsRepo: ErrorRepo, var executorRepo: ExecutorRepo, var executorTypeRepo: TaskExecutorTypeRepo, authorizer: Authorizer, @Lazy tasksActorApi: TasksActorApi, executionEngine: ExecutionEngine? = null) : TaskServiceBase, TaskServiceApi

TaskServiceApi

interface TaskServiceApi

TaskServiceBase

interface TaskServiceBase

TaskServiceSpringConfiguration

@Configuration

@EnableScheduling

class TaskServiceSpringConfiguration

TasksRestController

@RestController

@RequestMapping(value = ["/api/"])

class TasksRestController(config: TaskControllerConfig, taskService: TaskService, taskRepo: TaskRepo, pluginManagerService: PluginManagerService)

TaskTakeForExecutionResult

data class TaskTakeForExecutionResult(val task: TaskEntity?, val busy: Boolean = false)