Packages

yggdrasil

1.0.0
6.0.3 6.0.2 6.0.1 6.0.0 5.0.2 5.0.1 5.0.0 4.1.6 4.1.5 4.1.4 4.1.3 4.1.2 4.1.1 4.1.0 4.0.0 3.3.4 3.3.3 3.3.2 3.3.1 3.3.0 3.2.3 3.2.2 3.2.1 3.2.0 3.1.0 3.0.3 3.0.2 3.0.1 3.0.0 2.1.0 2.0.8 2.0.7 2.0.6 2.0.5 2.0.4 2.0.3 2.0.2 2.0.1 2.0.0 1.2.3 1.2.2 1.2.1 1.1.1 1.1.0 1.0.0

Agnostic pub/sub with Redis, RabbitMQ and Postgres support

HexDocs

Current section

Files

Jump to
Readme
45 Versions
2 Dependencies
Dependants
Files
Activity
yggdrasil lib yggdrasil.ex
Raw

lib/yggdrasil.ex 

defmodule Yggdrasil do

  use Application



  @proxy_name Yggdrasil.Proxy

  @broker_sup_name Yggdrasil.MessengerSupervisor

  @feed_name Yggdrasil.Feed

  @forwarder_name Yggdrasil.Util.Forwarder

  @messengers_table Yggdrasil.Messengers

  @subscribers_table Yggdrasil.Subscribers

  

  def start(_type, _args) do

    import Supervisor.Spec, warn: false



    messengers = :ets.new @messengers_table,

                          [:set, :named_table, :public, read_concurrency: true]

    subscribers = :ets.new @subscribers_table,

                           [:set, :named_table, :public,

                            read_concurrency: true]

    children = [

      worker(@proxy_name, [[name: @proxy_name]]),

      supervisor(@broker_sup_name, [[name: @broker_sup_name]]),

      worker(@feed_name,

             [@broker_sup_name, @proxy_name, subscribers, messengers,

              nil, [name: @feed_name]])

    ]

    opts = [strategy: :rest_for_one, name: Yggdrasil.Supervisor]

    case Mix.env do

      :prod ->

        Supervisor.start_link children, opts

      _ ->

        test_children = [worker(@forwarder_name, [[name: @forwarder_name]]) |

                         children]

        Supervisor.start_link test_children, opts

    end

  end

end