Packages

opq

0.1.0
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.ex
Raw

lib/opq.ex 

defmodule OPQ do

  @moduledoc """

  A simple, in-memory queue with pooling in Elixir.

  """



  alias OPQ.{Options, Feeder, WorkerSupervisor}



  def init(opts \\ []) do

    opts

    |> Options.assign_defaults

    |> start_links

  end



  def enqueue(feeder, event) do

    GenStage.call(feeder, {:enqueue, event})

  end



  def info(feeder) do

    GenStage.call(feeder, :info)

  end



  defp start_links(opts) do

    {:ok, feeder} = Feeder.start_link(opts[:name])

    opts          = Keyword.merge(opts, [name: feeder])

    {:ok, _}      = WorkerSupervisor.start_link(opts)



    {:ok, feeder}

  end

end