Package-level declarations¶
Types¶
| Name | Summary |
|---|---|
| DelayedTask | [jvm] class DelayedTask(clock: Clock, executionTime: Instant, val task: () -> Result) : Delayed A DelayedTask is a task that runs in the future |
| RepeatedTaskQueue | [jvm] class RepeatedTaskQueue : AbstractExecutionThreadService A RepeatedTaskQueue runs repeated tasks at a user controlled rate. Internally it uses a DelayQueue to hold the pending tasks; a background thread pulls the next task from the DelayQueue and hands it off to an executor service for execution. |
| RepeatedTaskQueueConfig | [jvm] data class RepeatedTaskQueueConfig@JvmOverloadsconstructor(val default_jitter_ms: Long = 50, val default_max_delay_sec: Long = 60, val num_parallel_tasks: Int = 1) |
| RepeatedTaskQueueFactory | [jvm] @Singleton class RepeatedTaskQueueFactory@Injectconstructor(clock: Clock, metrics: RepeatedTaskQueueMetrics, executorServiceFactory: ExecutorServiceFactory) |
| RepeatedTaskQueueMetrics | [jvm] @Singleton class RepeatedTaskQueueMetrics@Injectconstructor(metrics: Metrics) |
| Result | [jvm] data class Result(val status: Status, val nextDelay: Duration) |
| Status | [jvm] enum Status : Enum<Status> |