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

Package-level declarations

Types

object Daemon : CoroutineScope

The Grader Daemon singleton that is always running to handle database and messaging operations

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

Represents an executable job taking its corresponding payload

data class JobMessage(val job: String, val payload: String)

Represents a message containing the job name and the job payload

data class JobRequest(val job: Job<Payload>, val payload: Payload, val reservedRawJobMessage: String)

Represents a job containing the Job, the Payload this job accepts, and the original reservedRawJobMessage

object MessagingManager : Messenger, CoroutineScope

Contains methods for processing jobs from worker queues and subscribed channels

Abstraction for the message broker used in MessagingManager

private val dispatcher: ExecutorCoroutineDispatcher

private const val numThreads: Int = 2