Conduit.Dashboard

Types

typeQueueSummaryQueueSummary = {#

Functions

fnget_summaryget_summary(storage) : List(Conduit.Dashboard.QueueSummary)#

Return a JSON-serialisable summary of all queues.

Used by client-side 5-second polling (GET /conduit/api/summary).

fnstart_standalonestart_standalone(port : Int, storage, auth) : Task(())#

Start the dashboard as a standalone HTTP server on port.

Returns a Task handle. Call `task_await_unwrap(t)` to block until the server
exits (it won't under normal operation).

`port`    — TCP port to bind (e.g. 4001)
`storage` — any `Conduit.Storage` impl
`auth`    — `Auth.None | Auth.Token(t) | Auth.Fn(f)`

fnsubscribe_to_summarysubscribe_to_summary(storage) : ()#

Subscribe to real-time dashboard updates via Postgres NOTIFY.

Best-effort: with a connection pool, the LISTEN command targets whichever
connection is borrowed. Use the 5-second polling fallback for reliability.