JoobQ::Job

The JoobQ::Job module provides an abstract structure for defining jobs within the JoobQ asynchronous job processing framework. This module includes functionality for managing job statuses, scheduling, retries, timeouts, and more.

Example Usage

To define a custom job, include the JoobQ::Job module within your job class and implement the perform method.

class ExampleJob
  include JoobQ::Job

  def perform
    puts "Executing job logic"
  end
end

You can then enqueue, delay, or schedule the job using provided methods.

Job Status

The JoobQ::Job::Status enum defines the possible states for a job:

• Enqueued: The job has been enqueued and is waiting to be processed.
• Scheduled: The job is scheduled to run at a specific time.
• Running: The job is currently executing.
• Completed: The job finished successfully.
• Retrying: The job is retrying after a failure.
• Dead: The job execution failed after exhausting retries.
• Expired: The job expired before execution.

Each status has corresponding predicate and setter methods for checking and updating job status.

Properties

• jid: The unique identifier for the job (UUID).
• queue: The queue to which the job is assigned.
• retries: The number of retries remaining for this job.
• max_retries: The maximum number of retries allowed (set at job creation).
• expires: The expiration time of the job in Unix milliseconds.
• status: The current status of the job.
• timeout: The maximum execution time allowed for the job.

Methods

Status Predicate and Setter Methods

The module automatically defines predicate and setter methods for each job status:

job = ExampleJob.new
job.running! # Sets the job's status to Running
job.running? # Checks if the job's status is Running

Enqueue and Execution Methods

• batch_enqueue(jobs : Array({{type}})): Enqueues an array of jobs.

ExampleJob.batch_enqueue([job1, job2, job3])

• enqueue(**args): Enqueues a single job to the queue.

ExampleJob.enqueue(param: "value")

• perform: Executes the job immediately without enqueuing.

ExampleJob.perform(param: "value")

Delay and Scheduling

• enqueue_at(time : Time::Span, **args): Enqueues a job to be processed after a specified delay.

ExampleJob.enqueue_at(1.minute, param: "value")

• delay(for wait_time : Time::Span, **args): Delays job execution by a specified timespan.

ExampleJob.delay(2.minutes, param: "value")

• schedule(every : Time::Span, **args): Schedules a recurring job to run at a specified interval.

ExampleJob.schedule(5.seconds, param: "value")