tasks-client/org.artofdev.tasks.client.rest/TasksRestClient

TasksRestClient

class TasksRestClient(val url: String = "http://localhost:8080", val headersFactory: HttpHeadersFactory? = null)

Constructors

TasksRestClient

constructor(url: String = "http://localhost:8080", headersFactory: HttpHeadersFactory? = null)

constructor(url: String = "http://localhost:8080", headersFactory: HttpHeadersFactory? = null, requestTimeout: Duration)

Types

object Companion

Properties

val headersFactory: HttpHeadersFactory?

val url: String

Functions

fun cancelTask(taskId: Long): Task

fun createTask(request: TaskRequest): Task

fun endTask(taskId: Long, request: EndTaskRequest): Task

fun getInput(taskId: Long): TaskData?

getPipelineTasksResults

fun getPipelineTasksResults(pipelineTaskId: Long, taskTypeHids: List<String>? = null, page: Int = 0, size: Int = 100, sort: List<String> = listOf("id,asc")): PageResponse<PipelineTaskResult>

fun getProgress(taskId: Long): TaskProgress?

fun getResult(taskId: Long): TaskResult

fun getTask(taskId: Long): Task

fun getTaskByHid(hid: String): Task

fun getTasks(page: Int = 0, size: Int = 100, sort: List<String> = listOf("id,asc"), runningStatuses: List<Task.RunningStatus> = emptyList(), taskTypeHids: List<String> = emptyList(), taskTypeCategory: TaskTypeCategory? = null, extId: String? = null, pipelineTaskId: Long? = null): PageResponse<TaskWithProgress>

getTaskTypeHids

fun getTaskTypeHids(): List<String>

fun getTaskTypes(): List<TaskType>

fun rerunTask(taskId: Long): Task

fun startTask(taskId: Long): Task

takeTaskForExecution

fun takeTaskForExecution(execTypeHid: String, executorHid: String): TaskExecDataResponse