RepeatedTaskManager

class RepeatedTaskManager @JvmOverloads constructor(meterRegistry: MeterRegistry)

Basic management of repeated tasks.

Constructors

RepeatedTaskManager

@JvmOverloads

fun RepeatedTaskManager(meterRegistry: MeterRegistry = Metrics.globalRegistry)

Functions

createTask

@JvmOverloads

fun createTask(name: String, meterRegistry: MeterRegistry = this.meterRegistry, repeatedTaskConfig: RepeatedTaskConfig = RepeatedTaskConfig(), retryPolicy: suspend RetryFailure<Throwable>.() -> RetryInstruction = defaultThrowableRetryPolicy + binaryExponentialBackoff( base = repeatedTaskConfig.defaultJitterMs, max = repeatedTaskConfig.defaultMaxDelayMs ), taskConfig: TaskConfig = TaskConfig(), task: (name: String, taskConfig: TaskConfig) -> Status): RepeatedTask

Creates the repeated task with the details supplied. If the repeated task already exists, a TaskAlreadyExistsException is thrown.

getTask

fun getTask(taskName: String): RepeatedTask

isTaskRunning

fun isTaskRunning(taskName: String): Boolean

Returns true if a repeated task with the name supplied is running. If the task does not exist or is not running, return false.

shutDown

fun shutDown()

taskExists

fun taskExists(taskName: String): Boolean