Backplane.AgentRuntime.Inbox (backplane_agent_runtime v1.10.49)

Copy Markdown

Bounded receiver inbox with payload-digest deduplication.

A duplicate correlation ID with the same digest returns the existing receipt. The same key with changed payload conflicts. Overflow is explicit.

Summary

Types

t()

Functions

deliver(inbox, message)
new(limit)

Types

t()

@type t() :: map()

Functions

deliver(inbox, message)

@spec deliver(t(), map()) ::
  {:ok, t(),
   %{status: :accepted, correlation_id: String.t(), digest: String.t()}}
  | {:error, Backplane.AgentRuntime.Error.t()}

new(limit)

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