Backplane.AgentRuntime.RecoveryHarness (backplane_agent_runtime v1.6.0)

Copy Markdown

Generic durable recovery and storage conformance harness.

The harness does not assume any specific durable backend. It runs staged commits, failed/stalled acknowledgements, and conservative recovery classification through the host-provided StorePort.

Summary

Types

t()

Functions

crash(impl, context, record, meta, window)
crash_window(window)
run(impl, context, record, meta)
run_failed(impl, context, record, meta)

Types

t()

@type t() :: map()

Functions

crash(impl, context, record, meta, window)

@spec crash(module(), term(), map(), map(), atom()) ::
  {:ok, map()} | {:error, Backplane.AgentRuntime.Error.t()}

crash_window(window)

@spec crash_window(atom()) ::
  :before_dispatch | :after_mutation | :before_result | :after_terminal

run(impl, context, record, meta)

@spec run(module(), term(), map(), map()) ::
  {:ok, map()} | {:error, Backplane.AgentRuntime.Error.t()}

run_failed(impl, context, record, meta)

@spec run_failed(module(), term(), map(), map()) ::
  {:ok, map()} | {:error, Backplane.AgentRuntime.Error.t()}