Synapse.Signal (Synapse v0.1.1)

Canonical registry of signal topics and their schemas.

Delegates to Synapse.Signal.Registry so topics can be declared via configuration or registered at runtime.

Summary

topic()

Registers a topic at runtime.

Resolves a type string (e.g., "review.request") into the canonical topic atom.

topics()

Lists all known topics.

type(topic)

Returns the wire-format type for the given topic.

Validates a payload for the provided topic and returns the normalized map.

@type topic() :: atom()

@spec register_topic(
  topic(),
  keyword()
) :: :ok | {:error, term()}

Registers a topic at runtime.

@spec topic_from_type(String.t()) :: {:ok, topic()} | :error

Resolves a type string (e.g., "review.request") into the canonical topic atom.

@spec topics() :: [topic()]

Lists all known topics.

@spec type(topic()) :: String.t()

Returns the wire-format type for the given topic.

@spec validate!(topic(), map()) :: map()

Validates a payload for the provided topic and returns the normalized map.