PubSub for job runs, so the Jobs page follows a run as it moves instead of
polling. Two topics: topic/0 hears every run, run_topic/1 one run. A
message is {:job_run, action, run}, where action is what happened
(:started, :progress, :paused, :completed, …).
Always published after the transaction that made the change has
committed, so a subscriber never hears of a change that rolled back
(PhoenixKit.Jobs.Engine).
Summary
Functions
Tells the subscribers what happened to run. Never raises.
The topic of one run.
Subscribes the caller to every run.
Subscribes the caller to one run.
The topic that hears every run.
Functions
@spec broadcast(PhoenixKit.Jobs.Run.t(), atom()) :: :ok
Tells the subscribers what happened to run. Never raises.
The topic of one run.
Subscribes the caller to every run.
Subscribes the caller to one run.
The topic that hears every run.