Proca.Pipes.Supervisor (proca v3.4.1)
Supervisor of Topology processes and Processing Workers.
The processes involved are:
Pipes.Registry - a process registry for all Pipes-related processes
Pipes.Connection - a process managing Queue connection
Pipes.Supervisor - supervises the whole processing hierarchy
|
|--- OrgSupervisor(org_id) --- Topology - manage queue/exchange setup for org_id
| - Worker1 |- Worker2
|--- OrgSupervisor(org_id2) -- Topology - for org_id2
.
.
Link to this section Summary
Functions
Returns a specification to start this module under a supervisor.
Callback implementation for DynamicSupervisor.init/1.
Restart org pipes topology if configuration chanaged
Link to this section Functions
child_spec(arg)
Returns a specification to start this module under a supervisor.
See Supervisor.
handle_connected()
handle_disconnected()
init(arg)
Callback implementation for DynamicSupervisor.init/1.
reload_child(org)
Restart org pipes topology if configuration chanaged