Packages

ex_esdb_gater

0.0.8
0.8.0 0.7.0 0.6.1 0.6.0 0.5.0 0.4.0 0.3.5 0.3.4 0.3.3 0.3.2 0.3.1 0.3.0 0.2.1 0.2.0 0.1.19 0.1.18 0.1.17 0.1.16 0.1.15 0.1.14 0.1.13 0.1.12 0.1.11 0.1.10 0.1.9 0.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.8 0.0.6 0.0.5 0.0.4 0.0.3 0.0.2 0.0.1

ExESDBGater is a API gateway and load balancer for ExESDB Stores

HexDocs

Current section

Files

Jump to
Readme
41 Versions
8 Dependencies
Dependants
Files
Activity
ex_esdb_gater lib ex_esdb_gater system.ex
Raw

lib/ex_esdb_gater/system.ex 

defmodule ExESDBGater.System do

  @moduledoc """

    The APISystem is responsible for starting and supervising the

    APIWorkers.

  """

  use Supervisor

  require Logger

  alias ExESDBGater.Themes, as: Themes

  alias BCUtils.PubSubManager



  @impl Supervisor

  def init(opts) do

    pub_sub = Keyword.get(opts, :pub_sub)

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



    children =

      [

        {Cluster.Supervisor, [topologies, [name: ExESDBGater.LibCluster]]},

        {ExESDBGater.ClusterMonitor, opts},

        maybe_add_pubsub(pub_sub),

        {ExESDBGater.API, opts}

      ]

      # Remove nil entries

      |> Enum.filter(& &1)



    IO.puts("#{Themes.system(self())} [Gater System] is UP!")

    Supervisor.init(children, strategy: :one_for_one)

  end



  def start_link(opts),

    do:

      Supervisor.start_link(

        __MODULE__,

        opts,

        name: __MODULE__

      )



  def child_spec(opts),

    do: %{

      id: __MODULE__,

      start: {__MODULE__, :start_link, [opts]},

      type: :supervisor,

      restart: :permanent,

      shutdown: 5000

    }



  # Helper function to conditionally add Phoenix.PubSub using PubSubManager

  defp maybe_add_pubsub(pub_sub_name) do

    PubSubManager.maybe_child_spec(pub_sub_name)

  end

end