ElGraph.Signal (ElGraph v0.3.0)

에이전트 간 메시지 (SPEC §5). CloudEvents 핵심 필드를 따른다.

타입은 점 구분 문자열("task.assigned")이며 matches?/2로 패턴 매칭한다: 정확 일치, 접두 와일드카드("task.*"), 전체("*").

Summary

Types

t()

Functions

ensure_id(signal)

전달 id를 보장한다(CloudEvents id) — 없으면 생성, 있으면 보존한다.

matches?(pattern, type)

시그널 타입이 패턴에 매칭되는지 — 정확 일치 / prefix.* / *.

Types

t()

@type t() :: %ElGraph.Signal{
  data: term(),
  id: String.t() | nil,
  source: String.t() | nil,
  subject: String.t() | nil,
  type: String.t()
}

Functions

ensure_id(signal)

@spec ensure_id(t()) :: t()

전달 id를 보장한다(CloudEvents id) — 없으면 생성, 있으면 보존한다.

버스는 발행 시 fan-out 전에 한 번 스탬프하므로, 같은 시그널의 모든 수신본(원격 노드 포함)이 동일 id를 갖는다. 수신 측은 이 id로 멱등 처리(ElGraph.Signal.Dedup)해 at-least-once 재전달(예: netsplit 회복)을 안전하게 무시한다 (SPEC §6).

matches?(pattern, type)

@spec matches?(String.t(), String.t()) :: boolean()

시그널 타입이 패턴에 매칭되는지 — 정확 일치 / prefix.* / *.