Mailglass.PubSub.Topics (Mailglass v1.0.0)

Copy Markdown View Source

Typed topic builder for Mailglass.PubSub (SEND-05, D-27). Every topic is prefixed mailglass: — Phase 6 LINT-06 PrefixedPubSubTopics enforces the prefix at lint time.

Topics emitted

  • events/1 — "mailglass:events:#{tenant_id}" — tenant-wide event stream
  • events/2 — "mailglass:events:#{tenant_id}:#{delivery_id}" — per-delivery
  • deliveries/1 — "mailglass:deliveries:#{tenant_id}" — delivery-list stream

Projector broadcasts on BOTH events/1 and events/2 after every successful projection update (D-04).

Summary

Functions

deliveries(tenant_id)

Returns the delivery-list stream topic for the given tenant.

events(tenant_id)

Returns the tenant-wide event stream topic.

events(tenant_id, delivery_id)

Returns the per-delivery event stream topic.

Functions

deliveries(tenant_id)

(since 0.1.0) 
@spec deliveries(String.t()) :: String.t()

Returns the delivery-list stream topic for the given tenant.

events(tenant_id)

(since 0.1.0) 
@spec events(String.t()) :: String.t()

Returns the tenant-wide event stream topic.

events(tenant_id, delivery_id)

(since 0.1.0) 
@spec events(String.t(), binary()) :: String.t()

Returns the per-delivery event stream topic.