Class: Karafka::Processing::ConsumerGroups::JobsBuilder

Inherits:
Object
  • Object
show all
Defined in:
lib/karafka/processing/consumer_groups/jobs_builder.rb

Overview

Class responsible for deciding what type of job should we build to run a given command and for building a proper job for it.

Instance Method Summary collapse

Instance Method Details

#consume(executor, messages) ⇒ Karafka::Processing::ConsumerGroups::Jobs::Consume

Returns consumption job.

Parameters:

Returns:



12
13
14
 
# File 'lib/karafka/processing/consumer_groups/jobs_builder.rb', line 12

def consume(executor, messages)
  Jobs::Consume.new(executor, messages)
end

#eofed(executor) ⇒ Karafka::Processing::ConsumerGroups::Jobs::Eofed

Returns eofed job.

Parameters:

Returns:



18
19
20
 
# File 'lib/karafka/processing/consumer_groups/jobs_builder.rb', line 18

def eofed(executor)
  Jobs::Eofed.new(executor)
end

#revoked(executor) ⇒ Karafka::Processing::ConsumerGroups::Jobs::Revoked

Returns revocation job.

Parameters:

Returns:



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

def revoked(executor)
  Jobs::Revoked.new(executor)
end

#shutdown(executor) ⇒ Karafka::Processing::ConsumerGroups::Jobs::Shutdown

Returns shutdown job.

Parameters:

Returns:



30
31
32
 
# File 'lib/karafka/processing/consumer_groups/jobs_builder.rb', line 30

def shutdown(executor)
  Jobs::Shutdown.new(executor)
end