Interface TaskRunningService

All Superinterfaces:

io.micrometer.core.instrument.binder.MeterBinder

All Known Implementing Classes:

TaskRunningServiceImpl

public interface TaskRunningService
extends io.micrometer.core.instrument.binder.MeterBinder

Author:

paul, anton

Method Summary

Modifier and Type	Method	Description
SubmittedTask	getSubmittedTask(String taskId)
Collection<SubmittedTask>	getSubmittedTasks()
<T extends Task<?>> String	submitTask(T task)
<C extends TaskCommand> String	submitTaskCommand(C taskCommand)	Submit a task and track its progress.

Methods inherited from interface io.micrometer.core.instrument.binder.MeterBinder

bindTo

Method Details

getSubmittedTask

SubmittedTask getSubmittedTask(String taskId)

getSubmittedTasks

Collection<SubmittedTask> getSubmittedTasks()

Returns:

the submittedTasks

submitTask

<T extends Task<?>> String submitTask(T task)

submitTaskCommand

<C extends TaskCommand> String submitTaskCommand(C taskCommand)

Submit a task and track its progress. When it is finished, the results can be retrieved with checkResult(). Tasks can be cancelled with cancelTask().

Type Parameters:

C - task command implementation

Parameters:

taskCommand - The command to run. The submissionTime of the task is set after this call. This does not mean that the job has started - it might be queued.

Returns:

string