TaskBunny v0.0.1-dev.8 TaskBunny.Status.Worker

Modules that handles the Worker status.

Summary

Types

t()

The Worker status contains the follow fields:

queue, the name of queue the worker is listening to.
runners, the amount of runners currently running the Job.
channel, the connected channel with consumer tag or false if not connected.
stats, the amount of failed and succeeded jobs

Functions

get(pid)

Returns the Worker status

Types

t()

t() :: %TaskBunny.Status.Worker{channel: false | String.t, consuming: boolean, queue: String.t, runners: integer, stats: %{failed: integer, succeeded: integer, rejected: integer}}

The Worker status contains the follow fields:

queue, the name of queue the worker is listening to.
runners, the amount of runners currently running the Job.
channel, the connected channel with consumer tag or false if not connected.
stats, the amount of failed and succeeded jobs.

Functions

get(pid)

get({any, pid, atom, list}) :: TaskBunny.Status.Worker.t

get(pid) :: TaskBunny.Status.Worker.t

Returns the Worker status.