pub type Event {
  RequestQueued(request_id.RequestId, pool: String, at: Int)
  RequestStarted(
    request_id.RequestId,
    pool: String,
    wait_duration: Int,
  )
  RequestCompleted(
    request_id.RequestId,
    pool: String,
    handler_duration: Int,
    total_duration: Int,
  )
  RequestRejected(
    request_id.RequestId,
    pool: String,
    reason: error.ExecuteError,
  )
  RequestTimedOut(request_id.RequestId, pool: String)
  RequestFailed(request_id.RequestId, pool: String)
  WorkerStarted(pool: String, worker_id: Int)
  WorkerReplaced(pool: String, previous: Int, replacement: Int)
  RuntimeStopping
  RuntimeStopped
  JobInserted(job.JobId, queue: String)
  QueueClaimCompleted(
    queue: String,
    requested: Int,
    returned: Int,
    duration_ms: Int,
  )
  JobClaimed(job.JobId, queue: String, attempt: Int)
  JobStarted(job.JobId, queue: String, attempt: Int)
  JobCompleted(job.JobId, queue: String)
  JobCompletionPersisted(
    job.JobId,
    queue: String,
    duration_ms: Int,
  )
  JobRetryScheduled(job.JobId, queue: String, available_at: Int)
  JobDiscarded(job.JobId, queue: String)
  LeaseRenewalDeferred(job.JobId, queue: String, expires_at: Int)
  LeaseRenewed(job.JobId, queue: String, expires_at: Int)
  JobPersistenceFailed(
    job.JobId,
    queue: String,
    operation: String,
    reason: store.Error,
  )
  QueueClaimFailed(queue: String, reason: store.Error)
}

Constructors

• RequestQueued(request_id.RequestId, pool: String, at: Int)

• RequestStarted(
    request_id.RequestId,
    pool: String,
    wait_duration: Int,
  )

• RequestCompleted(
    request_id.RequestId,
    pool: String,
    handler_duration: Int,
    total_duration: Int,
  )

• RequestRejected(
    request_id.RequestId,
    pool: String,
    reason: error.ExecuteError,
  )

• RequestTimedOut(request_id.RequestId, pool: String)

• RequestFailed(request_id.RequestId, pool: String)

• WorkerStarted(pool: String, worker_id: Int)

• WorkerReplaced(pool: String, previous: Int, replacement: Int)

• RuntimeStopping

• RuntimeStopped

• JobInserted(job.JobId, queue: String)

• QueueClaimCompleted(
    queue: String,
    requested: Int,
    returned: Int,
    duration_ms: Int,
  )

• JobClaimed(job.JobId, queue: String, attempt: Int)

• JobStarted(job.JobId, queue: String, attempt: Int)

• JobCompleted(job.JobId, queue: String)

• JobCompletionPersisted(
    job.JobId,
    queue: String,
    duration_ms: Int,
  )

• JobRetryScheduled(job.JobId, queue: String, available_at: Int)

• JobDiscarded(job.JobId, queue: String)

• LeaseRenewalDeferred(job.JobId, queue: String, expires_at: Int)

• LeaseRenewed(job.JobId, queue: String, expires_at: Int)

• JobPersistenceFailed(
    job.JobId,
    queue: String,
    operation: String,
    reason: store.Error,
  )

• QueueClaimFailed(queue: String, reason: store.Error)