Sha256: 9decebfc26fdec91c0d4c3e06ed122dccac1fb5e4b0546026786ae9550dc181e
Contents?: true
Size: 718 Bytes
Versions: 77
Compression:
Stored size: 718 Bytes
Contents
# frozen_string_literal: true
module Karafka
module Processing
# FIFO scheduler for messages coming from various topics and partitions
class Scheduler
# Schedules jobs in the fifo order
#
# @param queue [Karafka::Processing::JobsQueue] queue where we want to put the jobs
# @param jobs_array [Array<Karafka::Processing::Jobs::Base>] jobs we want to schedule
def schedule_consumption(queue, jobs_array)
jobs_array.each do |job|
queue << job
end
end
# Both revocation and shutdown jobs can also run in fifo by default
alias schedule_revocation schedule_consumption
alias schedule_shutdown schedule_consumption
end
end
end
Version data entries
77 entries across 77 versions & 1 rubygems