Class: Karafka::Processing::Scheduler

Inherits:

Object

• Object
• Karafka::Processing::Scheduler

Defined in:

lib/karafka/processing/scheduler.rb

Overview

FIFO scheduler for messages coming from various topics and partitions

Direct Known Subclasses

Karafka::Pro::Processing::Scheduler

Instance Method Summary

• #schedule_consumption(queue, jobs_array) ⇒ Object (also: #schedule_revocation, #schedule_shutdown)

  Schedules jobs in the fifo order.

Instance Method Details

#schedule_consumption(queue, jobs_array) ⇒ Object Also known as: schedule_revocation, schedule_shutdown

Schedules jobs in the fifo order

Parameters:

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

  queue where we want to put the jobs

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

  jobs we want to schedule

# File 'lib/karafka/processing/scheduler.rb', line 11

def schedule_consumption(queue, jobs_array)
  jobs_array.each do |job|
    queue << job
  end
end