TaskBunny

v0.3.4

TaskBunny v0.3.4 TaskBunny.Config View Source

Handles TaskBunny configuration.

Link to this section Summary

Functions

auto_start?()

Returns true if auto start is enabled

connect_options(host)

Returns connect options for the host

disable_auto_start()

Disable auto start manually

disable_worker?()

Returns true if worker is disabled

failure_backend()

Returns the list of failure backends

host_config(host)

Returns configuration for the host

hosts()

Returns list of hosts

publisher_max_overflow()

Returns the max overflow for the publisher poolboy. 0 by default

publisher_pool_size()

Returns the publisher pool size for poolboy. 15 by default

queue_for_job(job)

Returns a queue for the given job

queues()

Returns list of queues

workers()

Transforms queue configuration into list of workers for the application to run

Link to this section Functions

Link to this function auto_start?() View Source 
auto_start?() :: boolean()

Returns true if auto start is enabled.

Link to this function connect_options(host) View Source 
connect_options(host :: atom()) :: list() | String.t()

Returns connect options for the host.

Link to this function disable_auto_start() View Source 
disable_auto_start() :: :ok

Disable auto start manually.

Link to this function disable_worker?() View Source 
disable_worker?() :: boolean()

Returns true if worker is disabled.

Link to this function failure_backend() View Source 
failure_backend() :: [atom()]

Returns the list of failure backends.

It returns TaskBunny.FailureBackend.Logger by default.

Link to this function host_config(host) View Source 
host_config(atom()) :: keyword() | nil

Returns configuration for the host.

Examples 

iex> host_config(:default)
[connection_options: "amqp://localhost?heartbeat=30"]
Link to this function hosts() View Source 
hosts() :: [atom()]

Returns list of hosts.

Link to this function publisher_max_overflow() View Source 
publisher_max_overflow() :: integer()

Returns the max overflow for the publisher poolboy. 0 by default

Link to this function publisher_pool_size() View Source 
publisher_pool_size() :: integer()

Returns the publisher pool size for poolboy. 15 by default

Link to this function queue_for_job(job) View Source 
queue_for_job(atom()) :: keyword() | nil

Returns a queue for the given job.

Link to this function queues() View Source 
queues() :: [keyword()]

Returns list of queues.

Link to this function workers() View Source 
workers() :: [keyword()]

Transforms queue configuration into list of workers for the application to run.