Exq.Scheduler.Server (exq v0.23.0)
View SourceThe Scheduler is responsible for monitoring the schedule and retry queues.
These queues use a Redis sorted set (term?) to schedule and pick off due jobs.
Once a job is at or past it's execution date, the Scheduler moves the job into the
live execution queue.
Runs on a timed loop according to scheduler_poll_timeout.
Initialization:
:name- Name of target registered process:namespace- Redis namespace to store all data under. Defaults to "exq".:queues- Array of currently active queues (TODO: Remove, I suspect it's not needed).:redis- pid of Redis process.:scheduler_poll_timeout- How often to poll Redis for scheduled / retry jobs.
Summary
Functions
Returns a specification to start this module under a supervisor.
Dequeue any active jobs in the scheduled and retry queues, and enqueue them to live queue.
Callback implementation for GenServer.init/1.
Functions
Returns a specification to start this module under a supervisor.
See Supervisor.
Dequeue any active jobs in the scheduled and retry queues, and enqueue them to live queue.
Callback implementation for GenServer.init/1.