klokka-core/com.eventslooped.klokka/JobEvent

JobEvent

sealed interface JobEvent

In-process lifecycle events, emitted by the runtime as a hot kotlinx.coroutines.flow.SharedFlow. This is the only observability primitive in the core: metrics and tracing modules are built on it, and applications may subscribe directly for custom alerting.

Inheritors

Types

Cancelled

data class Cancelled(val jobId: JobId, val kind: String, val at: Instant, val scheduleId: String? = null) : JobEvent

DeadLettered

data class DeadLettered(val jobId: JobId, val kind: String, val at: Instant, val attempts: Int, val error: Throwable, val scheduleId: String? = null) : JobEvent

Enqueued

data class Enqueued(val jobId: JobId, val kind: String, val at: Instant, val queue: QueueName, val scheduledFor: Instant, val scheduleId: String? = null) : JobEvent

FailedAttempt

data class FailedAttempt(val jobId: JobId, val kind: String, val at: Instant, val attempt: Int, val error: Throwable, val retryAt: Instant?, val scheduleId: String? = null) : JobEvent

ScheduleMisfired

data class ScheduleMisfired(val scheduleId: String, val kind: String, val at: Instant, val missedFires: Int, val policy: MisfirePolicy, val emitted: Int) : JobEvent

A recurring schedule came due later than its misfire threshold allowed. There is no per-run job id here because a misfire is a schedule-level fact: with MisfirePolicy.Skip no run exists at all. missedFires counts the fire times inside the missed window; emitted is how many runs the policy actually produced (0 for Skip, 1 for FireOnce, up to atMost for CatchUp).

Started

data class Started(val jobId: JobId, val kind: String, val at: Instant, val attempt: Int, val queueWait: Duration, val scheduleId: String? = null) : JobEvent

Succeeded

data class Succeeded(val jobId: JobId, val kind: String, val at: Instant, val attempt: Int, val runDuration: Duration, val late: Boolean, val scheduleId: String? = null) : JobEvent

Properties

abstract val at: Instant

kind

abstract val kind: String

scheduleId

abstract val scheduleId: String?

Id of the recurring schedule this event belongs to; null for directly enqueued jobs.