Roger.Partition.WorkerSupervisor (roger v4.0.1)

Copy Markdown View Source

The per-partition supervisor for job workers.

Workers processes are spawned on-demand from the Roger.Partition.Consumer process as soon as a job is ready to be processed.

Summary

Functions

child_spec(arg)

Returns a specification to start this module under a supervisor.

start_child(partition, channel, payload, meta)

Start a job worker process in the supervisor

Functions

child_spec(arg)

Returns a specification to start this module under a supervisor.

See Supervisor.

start_child(partition, channel, payload, meta)

Start a job worker process in the supervisor