redis-daemon/dev.ust.zinc.grader.daemon/Job

Job

open class Job<PayloadT : Payload>(val jobName: String) : CoroutineScope

Represents an executable job taking its corresponding payload

Open for new jobs to extend and implement how it handlePayload

Job has its own thread pool for executing possibly heavy-duty operations in handlePayload

Also stores parsing logic related to JobMessage and JobRequest

Inheritors

ConfigValidated

Constructors

constructor(jobName: String)

Types

object Companion

Properties

coroutineContext

open override val coroutineContext: CoroutineContext

val jobName: String

name of the job, that is the IPC topic name

Functions

open suspend fun handlePayload(payload: PayloadT)

fun packagePayload(payload: Payload): JobMessage