Class: Karafka::Processing::JobsBuilder

Inherits:

Object

show all

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.



11
12
13

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

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



17
18
19

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

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



23
24
25

# File 'lib/karafka/processing/jobs_builder.rb', line 23

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



29
30
31

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

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