Class: Karafka::Processing::JobsBuilder
- Inherits:
-
Object
- Object
- Karafka::Processing::JobsBuilder
- Defined in:
- lib/karafka/processing/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.
Direct Known Subclasses
Instance Method Summary collapse
-
#consume(executor, messages) ⇒ Karafka::Processing::Jobs::Consume
Consumption job.
-
#revoked(executor) ⇒ Karafka::Processing::Jobs::Revoked
Revocation job.
-
#shutdown(executor) ⇒ Karafka::Processing::Jobs::Shutdown
Shutdown job.
Instance Method Details
#consume(executor, messages) ⇒ Karafka::Processing::Jobs::Consume
Returns consumption job.
11 12 13 |
# File 'lib/karafka/processing/jobs_builder.rb', line 11 def consume(executor, ) Jobs::Consume.new(executor, ) end |
#revoked(executor) ⇒ Karafka::Processing::Jobs::Revoked
Returns revocation job.
17 18 19 |
# File 'lib/karafka/processing/jobs_builder.rb', line 17 def revoked(executor) Jobs::Revoked.new(executor) end |
#shutdown(executor) ⇒ Karafka::Processing::Jobs::Shutdown
Returns shutdown job.
23 24 25 |
# File 'lib/karafka/processing/jobs_builder.rb', line 23 def shutdown(executor) Jobs::Shutdown.new(executor) end |