tasks-controller/org.artofdev.tasks.controller.db

Package-level declarations

Types

interface ErrorRepo : JpaRepository<TaskErrorEntity, Long> , JpaSpecificationExecutor<TaskErrorEntity>

@Entity

data class Executor(var id: Int = 0, var hid: String? = null, var hostname: String? = null, var type: TaskExecutorType, val createTime: Instant, var lastAliveTime: Instant? = null)

ExecutorRepo

interface ExecutorRepo : JpaRepository<Executor, Int> , JpaSpecificationExecutor<Executor>

PipelineTaskTypeEntity

@Entity

data class PipelineTaskTypeEntity(var id: Long, val pipelineTask: TaskEntity, val taskType: TaskTypeEntity, var state: PipelineTaskTypeState = PipelineTaskTypeState.DoneCreating)

PipelineTaskTypeRepo

interface PipelineTaskTypeRepo : JpaRepository<PipelineTaskTypeEntity, Long>

PipelineTaskTypeState

enum PipelineTaskTypeState : Enum<PipelineTaskTypeState>

PipelineTaskTypeStateConverter

class PipelineTaskTypeStateConverter : AttributeConverter<PipelineTaskTypeState, Int>

TaskCategory

enum TaskCategory : Enum<TaskCategory>

TaskCategoryConverter

class TaskCategoryConverter : AttributeConverter<TaskCategory, Int>

TaskEntity

@Entity

data class TaskEntity(var id: Long, var hid: String? = null, var extId: String? = null, val type: TaskTypeEntity, val parentTask: TaskEntity? = null, val name: String?, val orderKey: String? = null, val pipelineTask: TaskEntity? = null, val isExternal: Boolean = false, var isCancelled: Boolean = false, var runningStatus: Int, var errorLevel: Int? = null, var finishedOk: Boolean? = null, var executor: Executor? = null, val ownerTenantId: Int, val ownerUserId: Int, val createTime: Instant, var updateTime: Instant, var extraData: TaskExtraData, var finishingState: TaskFinishingState? = null)

TaskErrorEntity

@Entity

data class TaskErrorEntity(var id: Long = 0, val task: TaskEntity, val severity: TaskError.Severity, val code: String? = null, val message: String, val createTime: Instant = Instant.now(), val ownerTenantId: Int, val ownerUserId: Int)

TaskExecutor

@Entity

data class TaskExecutor(var id: Long, val type: TaskExecutorType, val createTime: Instant, val ownerTenantId: Int, val ownerUserId: Int)

TaskExecutorType

@Entity

data class TaskExecutorType(var id: Long, val hid: String, val executable: String? = null, val parallelMax: Int, val externalDeployment: Boolean = false)

TaskExecutorTypeRepo

interface TaskExecutorTypeRepo : JpaRepository<TaskExecutorType, Long> , JpaSpecificationExecutor<TaskExecutorType>

TaskExtraData

data class TaskExtraData(var progress: TaskProgress? = null, val input: TaskData? = null, var output: TaskData? = null)

TaskFinishingState

enum TaskFinishingState : Enum<TaskFinishingState>

TaskFinishingStateConverter

class TaskFinishingStateConverter : AttributeConverter<TaskFinishingState, Int>

TaskRepo

interface TaskRepo : JpaRepository<TaskEntity, Long> , JpaSpecificationExecutor<TaskEntity>

TaskTypeEntity

@Entity

data class TaskTypeEntity(var id: Long, val hid: String, val category: TaskCategory, val ordered: Boolean = false)

TaskTypeRepo

interface TaskTypeRepo : JpaRepository<TaskTypeEntity, Long> , JpaSpecificationExecutor<TaskTypeEntity>

Functions

toDto

fun TaskCategory.toDto(): TaskTypeCategory

fun TaskEntity.toDto(): Task

fun TaskTypeEntity.toDto(): TaskType

toEntity

fun TaskTypeCategory.toEntity(): TaskCategory

toTaskWithState

fun TaskEntity.toTaskWithState(): TaskWithProgress