Packages
honeydew
1.1.6
1.5.0
1.4.6
1.4.5
1.4.4
1.4.3
1.4.2
1.4.1
1.4.0
1.3.0
1.2.8
1.2.7
1.2.6
1.2.5
1.2.4
1.2.3
1.2.2
1.2.1
1.2.0
1.1.6
1.1.5
1.1.4
1.1.3
1.1.2
1.1.1
1.1.0
1.0.4
1.0.3
1.0.2
1.0.1
1.0.0
1.0.0-rc7
1.0.0-rc6
1.0.0-rc5
1.0.0-rc4
1.0.0-rc3
1.0.0-rc2
1.0.0-rc1
0.0.11
0.0.10
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
Pluggable local/clusterable job queue focused on safety.
Current section
Files
Jump to
Current section
Files
lib/honeydew/worker_groups_supervisor.ex
defmodule Honeydew.WorkerGroupsSupervisor do
use DynamicSupervisor
alias Honeydew.WorkerGroupSupervisor
def start_link([queue, _] = extra_args) do
supervisor_opts = [name: Honeydew.supervisor(queue, :worker_groups)]
DynamicSupervisor.start_link(__MODULE__, extra_args, supervisor_opts)
end
def start_group(queue, queue_pid) do
queue
|> Honeydew.supervisor(:worker_groups)
|> DynamicSupervisor.start_child({WorkerGroupSupervisor, queue_pid})
end
@impl true
def init(extra_args) do
DynamicSupervisor.init(strategy: :one_for_one, extra_arguments: extra_args)
end
end