ecto_job v3.1.0

EctoJob.WorkerSupervisor (ecto_job v3.1.0) View Source

GenStage ConsumerSupervisor that will spawn EctoJob.Worker tasks for jobs.

Link to this section Summary

Functions

start_link(list)

Starts the ConsumerSupervisor

Link to this section Functions

Link to this function

start_link(list)

View Source

Specs

start_link(config: EctoJob.Config.t(), subscribe_to: Keyword.t()) ::
  Supervisor.on_start()

Starts the ConsumerSupervisor

  • config : The JobQueue configuration, used for Repo, Logging options
  • subscribe_opts : Should contain [{producer_name, max_demand: max_demand}]