Class: Karafka::Processing::Schedulers::Default

Inherits:

Object

• Object
• Karafka::Processing::Schedulers::Default

Defined in:

lib/karafka/processing/schedulers/default.rb

Overview

FIFO scheduler for messages coming from various topics and partitions

Instance Method Summary

• #initialize(queue) ⇒ Default constructor

  A new instance of Default.

• #on_clear(_group_id) ⇒ Object

  This scheduler does not need to be cleared because it is stateless.

• #on_manage ⇒ Object

  This scheduler does not have anything to manage as it is a pass through and has no state.

• #on_schedule_consumption(jobs_array) ⇒ Object (also: #on_schedule_revocation, #on_schedule_shutdown, #on_schedule_idle)

  Schedules jobs in the fifo order.

Constructor Details

#initialize(queue) ⇒ Default

Returns a new instance of Default.

Parameters:

• queue (Karafka::Processing::JobsQueue) —

  queue where we want to put the jobs

# File 'lib/karafka/processing/schedulers/default.rb', line 10

def initialize(queue)
  @queue = queue
end

Instance Method Details

#on_clear(_group_id) ⇒ Object

This scheduler does not need to be cleared because it is stateless

Parameters:

• _group_id (String) —

  Subscription group id

# File 'lib/karafka/processing/schedulers/default.rb', line 36

def on_clear(_group_id)
  nil
end

#on_manage ⇒ Object

This scheduler does not have anything to manage as it is a pass through and has no state

# File 'lib/karafka/processing/schedulers/default.rb', line 29

def on_manage
  nil
end

#on_schedule_consumption(jobs_array) ⇒ Object Also known as: on_schedule_revocation, on_schedule_shutdown, on_schedule_idle

Schedules jobs in the fifo order

Parameters:

• jobs_array (Array<Karafka::Processing::Jobs::Consume>) —

  jobs we want to schedule

# File 'lib/karafka/processing/schedulers/default.rb', line 17

def on_schedule_consumption(jobs_array)
  jobs_array.each do |job|
    @queue << job
  end
end