Bedrock.JobQueue.Supervisor (bedrock_job_queue v0.2.0)

View Source

Supervises the consumer tree for a JobQueue module.

This supervisor is started by the JobQueue module's start_link/1 function and manages the Consumer supervision tree (Scanner, Manager, Worker pool).

Summary

Functions

child_spec(init_arg)

Returns a specification to start this module under a supervisor.

start_link(job_queue_module, opts \\ [])

Starts the supervisor for the given JobQueue module.

Functions

child_spec(init_arg)

Returns a specification to start this module under a supervisor.

See Supervisor.

start_link(job_queue_module, opts \\ [])

Starts the supervisor for the given JobQueue module.

Options

  • :concurrency - Number of concurrent workers (default: System.schedulers_online())
  • :batch_size - Items to dequeue per batch (default: 10)