JobManager

interface JobManager<C : KlerkContext, V>

Functions

Link copied to clipboard
abstract suspend fun awaitCompletion(id: JobId, timeout: Duration): JobMetadata?

Waits for the job to complete.

Link copied to clipboard
abstract fun getAllJobs(): List<JobMetadata>
Link copied to clipboard
abstract fun getJob(id: JobId): JobMetadata
Link copied to clipboard
abstract fun scheduleAction(action: Job<C, V>): JobId