Specs

extract_pid({:ok, pid()}) :: pid()

Extracts the pid from an {:ok, pid} tuple.

iex> pid = spawn_link(fn -> :hello end)
iex> pid == OddJob.Utils.extract_pid({:ok, pid})
true

Specs

link_and_monitor(pid()) :: {pid(), reference()}

Links and monitors the pid and returns the tuple {pid, monitor_ref}.

Example

iex> pid = spawn(fn -> [] end)
iex> {^pid, ref} = OddJob.Utils.link_and_monitor(pid)
iex> receive do
...>   {:DOWN, ^ref, :process, ^pid, :normal} -> :received
...> end
:received

Specs

pool_supervisor_name(term()) :: name()

Returns the OddJob.Pool.Supervisor name in :via for the given name.

iex> OddJob.Utils.pool_supervisor_name(:job)
{:via, Registry, {OddJob.Registry, {:job, :pool_sup}}}

Specs

proxy_sup_name(term()) :: name()

Returns the OddJob.Async.ProxySupervisor name in :via for the given name.

iex> OddJob.Utils.proxy_sup_name(:job)
{:via, Registry, {OddJob.Registry, {:job, :proxy_sup}}}

Specs

queue_name(term()) :: name()

Returns the OddJob.Queue name in :via for the given name.

iex> OddJob.Utils.queue_name(:job)
{:via, Registry, {OddJob.Registry, {:job, :queue}}}

Specs

scheduler_sup_name(term()) :: name()

Returns the OddJob.Scheduler.Supervisor name in :via for the given name.

iex> OddJob.Utils.scheduler_sup_name(:job)
{:via, Registry, {OddJob.Registry, {:job, :scheduler_sup}}}