Skip to main content

Module events

assay_workflow::api

Module events 

Source
Expand description

SSE endpoint for the engine-events outbox.

Endpoint: GET /api/v1/engine/workflow/events/stream Query params: ?ns= default “main” ?subsystem=<workflow|auth|secrets|system> repeatable ?workflow_id= optional ?kind= repeatable Header: Last-Event-ID: <i64> optional cursor for replay

Behaviour:

  1. Replay phase reads engine_events since Last-Event-ID (or from the beginning if absent) and emits matching frames.
  2. If the cursor is older than the namespace’s oldest retained id, returns HTTP 410 Gone so the client knows to snapshot + resync.
  3. Live phase subscribes to the node-local broadcast; emits the frames that pass the filter.
  4. broadcast::Lagged force-closes the stream — the client reconnects with the last id it saw and replays the gap via engine_events.

Functions§

router