Continuum.Runtime.Recovery (continuum v0.5.0)

Copy Markdown View Source

Boot-time recovery for orphaned durable work.

Recovery is intentionally narrow in v0.1: it does not execute work itself. It makes abandoned rows eligible for the existing dispatcher, timer wheel, and activity worker pollers after a node restart.

Summary

Functions

recover_once(opts \\ [])

Run one recovery scan.

Functions

recover_once(opts \\ [])

@spec recover_once(keyword()) ::
  {:ok,
   %{
     runs: non_neg_integer(),
     activity_tasks: non_neg_integer(),
     timers: non_neg_integer()
   }}
  | {:error, term()}

Run one recovery scan.