Module: RocketJob::Batch::Throttle

Extended by:

ActiveSupport::Concern

Included in:

RocketJob::Batch

Defined in:

lib/rocket_job/batch/throttle.rb

Overview

Rocket Job Batch Throttling Framework.

Example:

# Do not run any slices for this job when the MySQL slave delay exceeds 5 minutes.
class MyJob < RocketJob::Job
  include RocketJob::Batch

  # Define a custom mysql throttle
  # Prevents all slices from this job from running on the current server.
  define_batch_throttle :mysql_throttle_exceeded?

  def perform(record)
    # ....
  end

  private

  # Returns true if the MySQL slave delay exceeds 5 minutes
  def mysql_throttle_exceeded?
    status        = ActiveRecord::Base.connection.connection.select_one('show slave status')
    seconds_delay = Hash(status)['Seconds_Behind_Master'].to_i
    seconds_delay >= 300
  end
end

Defined Under Namespace

Modules: ClassMethods