Specs

add(atom(), pos_integer()) :: Supervisor.on_start_child()

It adds the queue running with the amount of size of workers. It always returns the child spec.

Returns a specification to start this module under a supervisor.

See Supervisor.

Specs

pause(atom()) :: boolean()

Specs

remove(atom()) :: :ok | {:error, :not_found}

It removes the queue. It returns :ok if successful and {:error, :not_found} otherwise.

Specs

resume(atom()) :: boolean()

Specs

status() :: [{atom(), pos_integer(), atom()}]

It returns the status of each queue currently.

[{:default, 25, :paused}, {:low_priority, 10, :running}]

Specs

status(atom()) :: :running | :paused

It returns the status of each queue currently.

[{:default, 25, :paused}, {:low_priority, 10, :running}]