Packages

ex_esdb_gater

0.2.1
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 pubsub_system.ex
Raw

lib/ex_esdb_gater/pubsub_system.ex 

defmodule ExESDBGater.PubSubSystem do

  @moduledoc """

  Supervisor for all PubSub instances used by ExESDBGater.

  """

  use Supervisor



  alias ExESDBGater.PubSubManager



  @pubsub_instances [:ex_esdb_events, :ex_esdb_system, :ex_esdb_logging]



  def start_link(opts) do

    name = Keyword.get(opts, :name, __MODULE__)

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

  end



  @impl true

  def init(_opts) do

    children =

      for name <- @pubsub_instances do

        PubSubManager.maybe_child_spec(name)

      end

      |> Enum.reject(&is_nil/1)



    Supervisor.init(children, strategy: :one_for_one)

  end

end