Proca.Pipes.Supervisor (proca v3.0.2)

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.

Link to this section Functions

Link to this function

child_spec(arg)

Returns a specification to start this module under a supervisor.

See Supervisor.

Link to this function

handle_connected()

Link to this function

handle_disconnected()

Callback implementation for DynamicSupervisor.init/1.

Link to this function

start_child(org)

Link to this function

start_link(arg)

Link to this function

terminate_child(org)