quasar_jobs/event

Canonical runtime telemetry. Reporters receive these events directly.

Types

Event

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)
  JobClaimed(job.JobId, queue: String, attempt: Int)
  JobStarted(job.JobId, queue: String, attempt: Int)
  JobCompleted(job.JobId, queue: String)
  JobRetryScheduled(job.JobId, queue: String, available_at: Int)
  JobDiscarded(job.JobId, queue: String)
  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)
```

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

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

```
JobCompleted(job.JobId, queue: String)
```

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

```
JobDiscarded(job.JobId, queue: String)
```

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

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

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