Packages
horde
0.6.1
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
Current section
Files
Jump to
Current section
Files
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, delta_crdt_options(options)},
{Horde.SupervisorImpl, Keyword.put(options, :name, root_name)},
{Horde.GracefulShutdownManager,
processes_pid: 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))
|> Keyword.put(:shutdown, :infinity)},
{Horde.SignalShutdown, signal_to: [graceful_shutdown_manager_name(root_name), root_name]},
{Horde.SupervisorTelemetryPoller, root_name}
]
Supervisor.init(children, strategy: :one_for_all)
end
defp delta_crdt_options(options) do
root_name = get_root_name(options)
crdt_options = Keyword.get(options, :delta_crdt_options, [])
mutable = [sync_interval: 300, max_sync_size: :infinite, shutdown: 30_000]
immutable = [
crdt: DeltaCrdt.AWLWWMap,
on_diffs: fn diffs -> on_diffs(diffs, root_name) end,
name: crdt_name(root_name)
]
Keyword.merge(mutable, crdt_options)
|> Keyword.merge(immutable)
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 on_diffs(diffs, root_name) do
try do
send(root_name, {:crdt_update, diffs})
rescue
ArgumentError ->
# the process might already been stopped
:ok
end
end
defp supervisor_name(name), do: :"#{name}.ProcessesSupervisor"
defp crdt_name(name), do: :"#{name}.Crdt"
defp graceful_shutdown_manager_name(name), do: :"#{name}.GracefulShutdownManager"
end