Packages

extreme_system

0.3.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