Backplane.AgentRuntime.Subscriber (backplane_agent_runtime v1.6.0)

Bounded event subscriptions with cursor retention and gap markers.

Slow subscribers cannot block execution. When a cursor expires, replay explicitly requests a snapshot instead of silently losing events.

Summary

t()

new(retention)

@type t() :: map()

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

@spec gap(t(), non_neg_integer()) :: {:ok, %{gap: boolean(), from: non_neg_integer()}}

@spec new(non_neg_integer()) ::
  {:ok, t()} | {:error, Backplane.AgentRuntime.Error.t()}

@spec replay(t(), non_neg_integer()) ::
  {:ok, list(), keyword()} | {:error, Backplane.AgentRuntime.Error.t()}