Module dispatch_queue

Module dispatch_queue 

Source
Expand description

Pending Dispatch payloads awaiting agent long-poll (RFC-0005 §4.1 + plan 06).

The runtime applier UPSERTs into this table on every PlanAction::QueueDispatch / Effect::RemoteQueueDispatch. The GET /v1/agent/dispatch long-poll handler take_for_host()-s a single row, deleting it atomically; failing to deliver doesn’t lose the intent because the reducer will re-emit on the next plan tick (the planner skips hosts with dispatch_acked_at set, so re-emission only happens when the prior Dispatch was never acked).

Structs§

DispatchQueue
QueuedDispatch

Functions§

parse_rfc3339 🔒
row_to_queued 🔒