SquidMesh.Runtime.StepRecovery (squid_mesh v0.1.0-alpha.3)

Copy Markdown View Source

Recovery helpers for step claims left running by interrupted workers.

Summary

Types

reclaim_result()
reclaim_status()

Functions

reclaim_stale_running_step(repo, step_run, timeout_ms)

Types

reclaim_result()

@type reclaim_result() :: {:ok, reclaim_status()} | {:error, term()}

reclaim_status()

@type reclaim_status() :: :reclaimed | :fresh | :not_running

Functions

reclaim_stale_running_step(repo, step_run, timeout_ms)

@spec reclaim_stale_running_step(
  module(),
  SquidMesh.Persistence.StepRun.t(),
  non_neg_integer()
) ::
  reclaim_result()