Packages

instream

1.0.0
2.2.1 2.2.0 2.1.0 2.0.0 2.0.0-rc.1 2.0.0-rc.0 1.0.0 0.22.0 0.21.0 0.20.0 0.19.0 0.18.0 0.17.1 0.17.0 0.16.0 0.15.0 0.14.0 0.13.0 0.12.0 0.11.0 0.10.0 0.9.0 0.8.0 0.7.0 0.6.0 0.5.0 0.4.0 0.3.0 0.2.0 0.1.0

InfluxDB driver for Elixir

HexDocs

Current section

Files

Jump to
Readme
30 Versions
4 Dependencies
Dependants
Files
Activity
instream lib instream connection supervisor.ex
Raw

lib/instream/connection/supervisor.ex 

defmodule Instream.Connection.Supervisor do

  @moduledoc false



  use Supervisor



  alias Instream.Pool.Worker



  @doc false

  def start_link(conn, name) do

    Supervisor.start_link(__MODULE__, conn, name: name)

  end



  @doc false

  def init(conn) do

    :ok =

      case conn.config([:init]) do

        nil -> :ok

        {mod, fun} -> apply(mod, fun, [conn])

      end



    Supervisor.init([pool_spec(conn)], strategy: :one_for_one)

  end



  defp pool_spec(conn) do

    pool_name = Module.concat(conn, Pool)



    pool_opts =

      (conn.config([:pool]) || [])

      |> Keyword.take([:size, :max_overflow])

      |> Keyword.put(:name, {:local, pool_name})

      |> Keyword.put(:worker_module, Worker)



    :poolboy.child_spec(conn, pool_opts, module: conn)

  end

end