View Source OddJob.Queue (OddJob v0.2.1)
The job queue that manages the assignments given to the pool workers.
Link to this section Summary
Link to this section Types
Specs
job() :: OddJob.Job.t()
Specs
t() :: %OddJob.Queue{
assigned: [pid()],
id: atom(),
jobs: [job()],
supervisor: atom(),
workers: [pid()]
}
The OddJob.Queue struct holds the state of the job queue.
:idis an atom representing the registered name of the queue process:supervisoris an atom representing the registered name of the queue's supervisor process:workersis a list of the active workerpids, whether they are busy working or not:assignedis a list of the workerpids that are currently assigned to a job:jobsis a list ofOddJob.Jobstructs representing the jobs that are queued to be performed when workers are available