Packages
verk
1.7.2
1.7.3
1.7.2
1.7.1
1.7.0
1.6.4
1.6.3
1.6.2
1.6.1
1.6.0
1.5.0
1.4.1
1.4.0
1.3.0
1.2.4
1.2.3
1.2.2
1.2.1
1.2.0
1.1.1
1.1.0
1.0.2
1.0.1
1.0.0
0.14.1
0.14.0
0.13.6
0.13.5
0.13.4
0.13.3
0.13.2
0.13.1
0.13.0
0.12.1
0.12.0
0.11.1
0.11.0
0.10.0
0.9.13
0.9.12
0.9.11
0.9.10
0.9.9
0.9.8
0.9.7
0.9.6
0.9.5
0.9.4
0.9.3
0.9.2
0.9.1
0.9.0
Verk is a job processing system backed by Redis.
Current section
Files
Jump to
Current section
Files
lib/verk/supervisor.ex
defmodule Verk.Supervisor do
@moduledoc """
Supervisor definition for Verk application. It consists of:
* `Verk.ScheduleManager`
* GenStage producer named `Verk.EventProducer`
* GenStage consumer `Verk.QueueStats`
* Redis connectionn named `Verk.Redis`
* A `Verk.Queue.Supervisor` per queue
"""
use Supervisor
@doc """
It starts the main supervisor
"""
def start_link(_ \\ []) do
Supervisor.start_link(__MODULE__, [], name: __MODULE__)
end
@doc false
def init(_) do
local_verk_node_id = verk_node_id()
Application.put_env(:verk, :local_node_id, local_verk_node_id)
supervise(children(), strategy: :one_for_one)
end
defp children do
redis_url = Confex.get_env(:verk, :redis_url)
shutdown_timeout = Confex.get_env(:verk, :shutdown_timeout, 30_000)
generate_node_id = Confex.get_env(:verk, :generate_node_id)
redis = worker(Redix, [redis_url, [name: Verk.Redis]], id: Verk.Redis)
event_producer = worker(Verk.EventProducer, [], id: Verk.EventProducer)
queue_stats = worker(Verk.QueueStats, [], id: Verk.QueueStats)
schedule_manager = worker(Verk.ScheduleManager, [], id: Verk.ScheduleManager)
manager_sup = supervisor(Verk.Manager.Supervisor, [], id: Verk.Manager.Supervisor)
drainer =
worker(
Verk.QueuesDrainer,
[shutdown_timeout],
id: Verk.QueuesDrainer,
shutdown: shutdown_timeout
)
children = [
redis,
event_producer,
queue_stats,
schedule_manager,
manager_sup,
drainer
]
if generate_node_id do
node_manager = worker(Verk.Node.Manager, [], id: Verk.Node.Manager)
List.insert_at(children, 1, node_manager)
else
children
end
end
defp verk_node_id do
case Application.fetch_env(:verk, :local_node_id) do
{:ok, local_verk_node_id} ->
local_verk_node_id
:error ->
if Confex.get_env(:verk, :generate_node_id, false) do
<<part1::32, part2::32>> = :crypto.strong_rand_bytes(8)
"#{part1}#{part2}"
else
Confex.get_env(:verk, :node_id, "1")
end
end
end
end