Class: Karafka::Processing::WorkersBatch

Inherits:
Object
  • Object
show all
Includes:
Enumerable
Defined in:
lib/karafka/processing/workers_batch.rb

Overview

Abstraction layer around workers batch.

Instance Method Summary collapse

Constructor Details

#initialize(jobs_queue) ⇒ WorkersBatch

Parameters:



14
15
16
 
# File 'lib/karafka/processing/workers_batch.rb', line 14

def initialize(jobs_queue)
  @batch = Array.new(concurrency) { Processing::Worker.new(jobs_queue) }
end

Instance Method Details

#each ⇒ Object

Iterates over available workers and yields each worker



19
20
21
 
# File 'lib/karafka/processing/workers_batch.rb', line 19

def each(&)
  @batch.each(&)
end

#size ⇒ Integer

Returns number of workers in the batch.

Returns:

  • (Integer) —

    number of workers in the batch



24
25
26
 
# File 'lib/karafka/processing/workers_batch.rb', line 24

def size
  @batch.size
end