Backplane.AgentRuntime.ExecutionController (backplane_agent_runtime v1.6.0)

Copy Markdown

One-run control owner that keeps store and backend work outside callbacks.

Cancellation can race a pending intent commit. Whichever transition commits first fences the other by revision; an intent acknowledgement observed after cancellation never restores dispatch authority.

Summary

Functions

await(server, timeout \\ 5000)
await_run_state(server, run_state, timeout \\ 5000)
cancel(server, at)
child_spec(init_arg)

Returns a specification to start this module under a supervisor.

settle_cleanup(server, at, settlement)
start_link(opts)
status(server)
submit(server, meta)

Functions

await(server, timeout \\ 5000)

@spec await(GenServer.server(), timeout()) :: term()

await_run_state(server, run_state, timeout \\ 5000)

@spec await_run_state(GenServer.server(), atom(), timeout()) :: map()

cancel(server, at)

@spec cancel(GenServer.server(), non_neg_integer()) ::
  {:ok, map()} | {:error, Backplane.AgentRuntime.Error.t()}

child_spec(init_arg)

Returns a specification to start this module under a supervisor.

See Supervisor.

settle_cleanup(server, at, settlement)

@spec settle_cleanup(GenServer.server(), non_neg_integer(), map()) ::
  {:ok, map()} | {:error, Backplane.AgentRuntime.Error.t()}

start_link(opts)

@spec start_link(keyword()) :: GenServer.on_start()

status(server)

@spec status(GenServer.server()) :: map()

submit(server, meta)

@spec submit(GenServer.server(), map()) ::
  {:ok, map()} | {:error, Backplane.AgentRuntime.Error.t()}