Packages

opq

0.1.1
4.0.4 4.0.3 4.0.2 4.0.1 4.0.0 3.3.0 3.2.0 3.1.1 3.1.0 3.0.1 3.0.0 2.0.1 2.0.0 1.0.1 1.0.0 0.1.1 0.1.0

A simple, in-memory queue with worker pooling and rate limiting in Elixir.

HexDocs

Current section

Files

Jump to
Readme
17 Versions
1 Dependency
Dependants
Files
Activity
opq lib opq worker_supervisor.ex
Raw

lib/opq/worker_supervisor.ex 

defmodule OPQ.WorkerSupervisor do

  @moduledoc """

  A supervisor that subscribes to `Feeder` and spins up the worker pool.

  """



  use ConsumerSupervisor



  def start_link(opts) do

    ConsumerSupervisor.start_link(__MODULE__, opts)

  end



  def init(opts) do

    children = [

      worker(opts[:worker], [], restart: :temporary)

    ]



    {

      :ok,

      children,

      strategy: :one_for_one,

      subscribe_to: [

        {opts[:name], min_demand: 0, max_demand: opts[:workers]}

      ]

    }

  end

end