Packages

horde

0.5.0-rc.4
0.10.0 0.9.1 0.9.0 0.8.7 0.8.6 0.8.5 0.8.4 0.8.3 0.8.2 0.8.1 0.8.0 0.8.0-rc.1 0.7.1 0.7.0 0.6.1 0.6.0 0.6.0-rc.1 0.5.0 0.5.0-rc.12 0.5.0-rc.11 0.5.0-rc.10 0.5.0-rc.9 0.5.0-rc.8 0.5.0-rc.7 0.5.0-rc.6 0.5.0-rc.5 0.5.0-rc.4 0.5.0-rc.3 0.5.0-rc.2 0.5.0-rc.1 0.4.0-rc.2 0.4.0-rc.1 0.3.0 0.3.0-rc1 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

Distributed supervisor & process registry built with DELTA-CRDTs

HexDocs

Current section

Files

Jump to
Readme
44 Versions
2 Dependencies
Dependants
Files
Activity
horde lib horde supervisor_supervisor.ex
Raw

lib/horde/supervisor_supervisor.ex 

defmodule Horde.SupervisorSupervisor do

  @moduledoc false



  use Supervisor



  def init(options) do

    root_name = get_root_name(options)



    children = [

      {DeltaCrdt,

       crdt: DeltaCrdt.AWLWWMap,

       notify: {root_name, :members_updated},

       name: members_crdt_name(root_name),

       sync_interval: 5,

       ship_interval: 5,

       ship_debounce: 1,

       shutdown: 30_000},

      {DeltaCrdt,

       crdt: DeltaCrdt.AWLWWMap,

       notify: {root_name, :members_status_updated},

       name: members_status_crdt_name(root_name),

       sync_interval: 5,

       ship_interval: 5,

       ship_debounce: 1,

       shutdown: 30_000},

      {DeltaCrdt,

       crdt: DeltaCrdt.AWLWWMap,

       notify: {root_name, :processes_updated},

       name: processes_crdt_name(root_name),

       sync_interval: 50,

       ship_interval: 50,

       ship_debounce: 400,

       shutdown: 30_000},

      {Horde.SupervisorImpl, Keyword.put(options, :name, root_name)},

      {Horde.GracefulShutdownManager,

       processes_pid: processes_crdt_name(root_name),

       name: graceful_shutdown_manager_name(root_name)},

      {Horde.DynamicSupervisor,

       Keyword.put(options, :name, supervisor_name(root_name))

       |> Keyword.put(:type, :supervisor)

       |> Keyword.put(:root_name, root_name)

       |> Keyword.put(:graceful_shutdown_manager, graceful_shutdown_manager_name(root_name))},

      {Horde.SignalShutdown, signal_to: [graceful_shutdown_manager_name(root_name), root_name]}

    ]



    Supervisor.init(children, strategy: :one_for_all)

  end



  defp get_root_name(options) do

    root_name = Keyword.get(options, :root_name, nil)



    if is_nil(root_name) do

      raise "root_name must be specified in options. got: #{inspect(options)}"

    end



    root_name

  end



  defp supervisor_name(name), do: :"#{name}.ProcessesSupervisor"

  defp members_crdt_name(name), do: :"#{name}.MembersCrdt"

  defp members_status_crdt_name(name), do: :"#{name}.MemberStatusCrdt"

  defp processes_crdt_name(name), do: :"#{name}.ProcessesCrdt"

  defp graceful_shutdown_manager_name(name), do: :"#{name}.GracefulShutdownManager"

end