Packages

libcluster

2.0.2
3.5.0 3.4.1 3.3.3 3.3.2 3.3.1 3.3.0 3.2.2 3.2.1 3.2.0 3.1.1 3.1.0 3.0.3 3.0.2 2.5.0 2.3.0 2.2.3 2.2.2 2.2.1 2.2.0 2.1.1 2.1.0 2.0.4 2.0.3 2.0.2 2.0.1 2.0.0 1.0.2 1.0.1 1.0.0 0.1.0

Automatic Erlang cluster formation and management for Elixir/Erlang applications

HexDocs

Current section

Files

Jump to
Readme
30 Versions
1 Dependency
Dependants
Files
Activity
libcluster lib app.ex
Raw

lib/app.ex 

defmodule Cluster.App do

  @doc false

  use Application



  def start(_type, _args) do

    import Supervisor.Spec, warn: false



    children = get_child_specs()

    opts = [strategy: :one_for_one, name: Cluster.Supervisor]

    Supervisor.start_link(children, opts)

  end



  defp get_child_specs() do

    import Supervisor.Spec, warn: false

    specs = Application.get_env(:libcluster, :topologies, [])

    for {topology, spec} <- specs do

      strategy       = Keyword.fetch!(spec, :strategy)

      config         = Keyword.get(spec, :config, [])

      connect_mfa    = Keyword.get(spec, :connect, {:net_kernel, :connect, []})

      disconnect_mfa = Keyword.get(spec, :disconnect, {:net_kernel, :disconnect, []})

      opts           = Keyword.get(spec, :child_spec, [])

      worker_args = [[

        topology: topology,

        connect: connect_mfa,

        disconnect: disconnect_mfa,

        config: config

      ]]

      worker(strategy, worker_args, opts)

    end

  end

end