Packages

snap

0.2.2
0.17.0 0.16.0 0.15.0 0.14.0 0.13.0 0.12.2 0.12.1 0.12.0 0.11.3 0.11.2 0.11.1 0.11.0 0.10.0 0.9.0 0.8.1 0.8.0 0.7.0 0.6.0 0.5.2 0.5.1 0.5.0 0.4.5 0.4.4 0.4.3 0.4.2 0.4.1 0.4.0 0.3.0 0.2.4 0.2.3 retired 0.2.2 0.2.1 0.2.0 0.1.1 0.1.0

A modern Elasticsearch/OpenSearch client

HexDocs

Current section

Files

Jump to
Readme
35 Versions
4 Dependencies
Dependants
Files
Activity
snap lib snap supervisor.ex
Raw

lib/snap/supervisor.ex 

defmodule Snap.Cluster.Supervisor do

  @moduledoc false



  use Supervisor

  @default_pool_size 5



  def start_link(cluster, otp_app, config) do

    Supervisor.start_link(__MODULE__, {cluster, otp_app, config}, name: cluster)

  end



  def config(cluster) do

    Snap.Config.get(config_name(cluster))

  end



  def connection_pool_name(cluster) do

    Module.concat(cluster, Pool)

  end



  ## Callbacks



  @doc false

  @impl Supervisor

  def init({cluster, _otp_app, config}) do

    children = [

      {Finch, finch_config(cluster, config)},

      {Snap.Config, {config_name(cluster), config}}

    ]



    Supervisor.init(children, strategy: :one_for_one)

  end



  defp finch_config(cluster, config) do

    url = Keyword.fetch!(config, :url)

    size = Keyword.get(config, :pool_size, @default_pool_size)



    [

      name: connection_pool_name(cluster),

      pools: %{

        url => [size: size, count: 1]

      }

    ]

  end



  defp config_name(cluster) do

    Module.concat(cluster, Config)

  end

end