klokka-core/com.eventslooped.klokka.spi/ClaimedJob

ClaimedJob

data class ClaimedJob(val id: JobId, val kind: String, val payload: String, val payloadVersion: Int, val queue: QueueName, val attempt: Int, val enqueuedAt: Instant, val scheduledFor: Instant, val leaseUntil: Instant, val fence: Long, val scheduleId: String? = null)

A job claimed under a lease, with everything a worker needs to execute it.

Constructors

ClaimedJob

constructor(id: JobId, kind: String, payload: String, payloadVersion: Int, queue: QueueName, attempt: Int, enqueuedAt: Instant, scheduledFor: Instant, leaseUntil: Instant, fence: Long, scheduleId: String? = null)

Properties

attempt

val attempt: Int

1-based attempt number of the execution about to happen.

enqueuedAt

val enqueuedAt: Instant

fence

val fence: Long

Fencing token: increases every time this job is claimed. Stores must reject writes (transition, heartbeat) carrying a stale fence, so a zombie worker resurrected after a pause cannot overwrite newer state.

val id: JobId

kind

val kind: String

leaseUntil

val leaseUntil: Instant

payload

val payload: String

payloadVersion

val payloadVersion: Int

queue

val queue: QueueName

scheduledFor

val scheduledFor: Instant

scheduleId

val scheduleId: String?

Id of the recurring schedule that emitted this run; null for directly enqueued jobs.