Durable.Activity (Durable v1.0.0)
View SourceOperational events worth an operator's attention, kept for a week in
durable.activity — the record behind "what happened to my queues?".
| kind | recorded when |
|---|---|
"stale_recovered" | runs whose node stopped heartbeating went back on the queue |
"zombie_recovered" | runs left running with no live worker were failed |
"worker_fenced" | a worker found its run reclaimed by another node and stopped |
"ack_failed" | a worker couldn't release a finished run's lock |
"queue_paused" | Durable.pause_queue/2 (details.by when given) |
"queue_resumed" | Durable.resume_queue/2 |
"schedule_disabled" | a schedule was turned off after failing repeatedly |
"pruned" | the retention pruner deleted finished runs |
Each row has :at, :kind, the :node_id that recorded it, and where it
applies :queue, :workflow_id, a :count and :details.
Recording never raises: losing an activity row must not break the recovery or the action it describes.
Summary
Functions
Recent activity, newest first.
Functions
@spec list(keyword()) :: [Durable.Storage.Schemas.ActivityEvent.t()]
Recent activity, newest first.
Options
:since- only events at or after this time (default: 24 hours ago):limit- at most this many (default: 100):durable- the Durable instance (default:Durable)