Std.App.Events

audience&Std.App.Events.Bus -> Str -> Array[Str]
The names of the subscribers an event on topic reaches.
fn
busStd.App.Events.Bus
A bus with no subscribers.
fn
Bus
Subscribers in the order they were added; delivery follows that order.
type
deadOf&Std.App.Events.Outbox -> Array[Std.App.Events.Event]
Events that exhausted their attempts.
fn
Delivery
What one publish did: how many subscribers took the event, and which
type
discard&Std.App.Events.Outbox -> Std.App.Events.Outbox
The outbox with everything staged since the last drain discarded, as
fn
drain&Std.App.Events.Outbox -> &Std.App.Events.Bus -> (Std.App.Events.Outbox, Std.App.Events.Delivery)
Publishes every pending event in order after a commit.
fn
eventStr -> Str -> Int -> Std.Json.Json -> Std.App.Events.Event
An event.
fn
Event
Something that happened, named by a dotted topic such as order.created.
type
fromJson&Std.Json.Json -> Option[Std.App.Events.Event]
An event read back from toJson.
fn
matchesStr -> Str -> Bool
Whether pattern selects topic.
fn
outboxInt -> Std.App.Events.Outbox
An empty outbox moving an event to dead after limit failed deliveries.
fn
Outbox
Events staged inside a unit of work, delivered only after it commits.
type
pendingOf&Std.App.Events.Outbox -> Array[Std.App.Events.Event]
Events awaiting delivery.
fn
publish&Std.App.Events.Bus -> &Std.App.Events.Event -> Std.App.Events.Delivery
Delivers an event to every matching subscriber.
fn
stage&Std.App.Events.Outbox -> Std.App.Events.Event -> Std.App.Events.Outbox
The outbox with one more event awaiting commit.
fn
Subscriber
A subscriber: the topic pattern it listens on, its name for reports, and
type
Subscribing
Adding subscribers reads top to bottom: Events.bus().on(...).on(...).
trait
toJson&Std.App.Events.Event -> Std.Json.Json
The event as a JSON object, for a durable outbox table or a log line.
fn