Packages

extreme_system

0.1.1
0.3.1 0.2.16 0.2.15 0.2.14 0.2.13 0.2.12 0.2.11 0.2.10 0.2.9 0.2.8 0.2.7 0.2.6 retired 0.2.5 0.2.4 0.2.3 0.2.2 0.2.1 0.2.0 0.1.5 0.1.4 0.1.3 0.1.2 0.1.1 0.1.0 0.0.9 0.0.8 0.0.7 0.0.6 0.0.5 0.0.4 0.0.3 0.0.2 0.0.1

Building blocks for distributed systems

HexDocs

Current section

Files

Jump to
Readme
33 Versions
3 Dependencies
Dependants
Files
Activity
extreme_system lib system command_configuration.ex
Raw

lib/system/command_configuration.ex 

defmodule Extreme.System.CommandConfiguration do

  defmacro __using__(opts) do

    quote do

      use     Supervisor

      require Logger

      

      def stream_for(), do: unquote(opts[:aggregates])



      def start_link(prefix),

        do: Supervisor.start_link __MODULE__, prefix, name: Extreme.System.CommandConfiguration.name(prefix)





      def init(prefix) do

        children = unquote(Keyword.fetch! opts, :aggregates) 

                    |> Enum.map(fn item -> aggregate_group(item, prefix) end)

        supervise children, strategy: :one_for_one

      end



      defp aggregate_group({aggr_mod, _stream}, prefix) do

        name = Extreme.System.AggregateGroup.name(aggr_mod)

        supervisor(Extreme.System.AggregateGroup, [prefix, aggr_mod], id: name)

      end

    end

  end



  def name(prefix),

    do: "#{prefix |> to_string()}.CommandConfiguration" |> String.to_atom

end