Packages

faktory_worker

1.9.3
1.9.10 1.9.9 1.9.8 1.9.7 1.9.6 1.9.5 1.9.4 1.9.3 1.9.2 1.9.1 1.9.0 1.8.2 1.8.1 1.8.0 1.7.0 1.6.0 1.5.0 1.4.0 1.3.0 1.2.0 1.1.0 1.0.0 0.1.0

A Faktory worker implementation for Elixir

HexDocs

Current section

Files

Jump to
Readme
23 Versions
4 Dependencies
Dependants
Files
Activity
faktory_worker lib faktory_worker pool.ex
Raw

lib/faktory_worker/pool.ex 

defmodule FaktoryWorker.Pool do

  @moduledoc false



  def child_spec(opts) do

    name = opts[:name]

    pool_name = format_pool_name(name)

    pool_config = Keyword.get(opts, :pool, [])



    :poolboy.child_spec(

      pool_name,

      [

        {:name, {:local, pool_name}},

        {:worker_module, FaktoryWorker.ConnectionManager.Server},

        {:size, Keyword.get(pool_config, :size, 10)},

        {:max_overflow, Keyword.get(pool_config, :size, 10)}

      ],

      Keyword.get(opts, :connection, [])

    )

  end



  @spec format_pool_name(name :: atom()) :: atom()

  def format_pool_name(name) when is_atom(name) do

    :"#{name}_pool"

  end

end