Public extension contract for atomic replay-key consumption.
Summary
Callbacks
@callback consume_replay_key(replay_key :: binary(), metadata :: map(), opts :: keyword()) :: :ok | {:error, Relyra.Error.t()}
Functions
@spec consume_replay_key(binary(), map(), keyword()) :: :ok | {:error, Relyra.Error.t()}