Packages
honeydew
1.5.0
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/workers_per_queue_supervisor.ex
defmodule Honeydew.WorkersPerQueueSupervisor do
@moduledoc false
use Supervisor, restart: :transient
alias Honeydew.WorkerSupervisor
alias Honeydew.QueueMonitor
def start_link(queue, opts, queue_pid) do
Supervisor.start_link(__MODULE__, [queue, opts, queue_pid], [])
end
@impl true
def init([queue, opts, queue_pid]) do
[
{WorkerSupervisor, [queue, opts, queue_pid]},
{QueueMonitor, [self(), queue_pid]}
]
|> Supervisor.init(strategy: :rest_for_one)
end
end