macula_pubsub_registry (macula v0.20.5)

Local subscription registry for pub/sub. Maps topic patterns to local subscribers (callback PIDs).

Summary

registry/0

subscription/0

Get specific subscription.

list_patterns(_)

List all unique patterns.

match(_, Topic)

Find subscriptions matching a topic.

new()

Create new empty registry.

size(_)

Get number of subscriptions.

Subscribe to a pattern. If subscription already exists (same subscriber_id + pattern), updates callback.

Unsubscribe from a pattern.

-type registry() ::
          #{subscriptions := [subscription()], pattern_index := #{binary() => [subscription()]}}.

-type subscription() :: #{subscriber_id := binary(), pattern := binary(), callback := pid()}.

-spec get_subscription(registry(), binary(), binary()) -> {ok, subscription()} | not_found.