Conduit.Dashboard.Actions

Conduit.Dashboard.Actions — write operations invoked by the dashboard UI.

All actions delegate to the Conduit public API or directly to storage. The router calls these after verifying auth; they return Result so the router can render an error page on failure.

Functions

fncancel_jobcancel_job(storage : s, job_id : String) : Result((), String)#

Cancel a job: set status = dead.

fncancel_workflowcancel_workflow(storage : s, wf_id : String) : Result((), String)#

Cancel a running workflow.

fndelete_all_dead_lettersdelete_all_dead_letters(storage : s) : Result(Int, String)#

Delete all dead letters in the table.

Returns the count of deleted rows on success.  Errors are propagated to the
caller so the router can render an appropriate error page.

fndelete_crondelete_cron(storage : s, cron_id : String) : Result((), String)#

Permanently delete a cron schedule.

fndelete_dead_letterdelete_dead_letter(storage, dl_id : String) : Result((), String)#

Delete a dead letter entry.

fndelete_jobdelete_job(storage : s, job_id : String) : Result((), String)#

Hard-delete a job row.

fnpause_cronpause_cron(storage : s, cron_id : String) : Result((), String)#

Pause a cron schedule (set enabled = false).

fnresume_cronresume_cron(storage : s, cron_id : String) : Result((), String)#

Resume a paused cron schedule (set enabled = true).

fnretry_all_dead_lettersretry_all_dead_letters(storage : s) : List(String)#

Retry all dead letters in the table.

Loads all dead letter rows via `dead_letter_list_all` (which fetches every
page, not just page 1) and re-enqueues each one.  Returns the list of newly
enqueued job ids.  Errors per entry are logged and skipped so one bad row
does not abort the rest.

fnretry_dead_letterretry_dead_letter(storage : s, dl_id : String) : Result(String, String)#

Retry a dead letter: re-enqueue the original job with a fresh attempt count and delete the dead letter entry.

Uses the original job's queue from the dead letter row.  Re-enqueues using
the performer's registered config if available (for correct backoff, DLQ, etc.);
falls back to safe defaults for jobs whose performer is no longer registered.

Returns the new job id on success.

fnretry_jobretry_job(storage : s, job_id : String) : Result((), String)#

Retry a job: reset to pending with attempt: 0.

fntrigger_cron_nowtrigger_cron_now(storage : s, cron_id : String) : Result(String, String)#

Trigger a cron job immediately (bypasses the schedule).