Class: Karafka::Processing::JobsBuilder

Inherits:

Object

Object
Karafka::Processing::JobsBuilder

show all

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

Karafka::Pro::Processing::JobsBuilder

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.

Parameters:

executor (Karafka::Processing::Executor)
messages (Karafka::Messages::Messages) —

messages batch to be consumed

Returns:

(Karafka::Processing::Jobs::Consume) —

consumption job



11
12
13

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

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

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

Returns revocation job.

Parameters:

executor (Karafka::Processing::Executor)

Returns:

(Karafka::Processing::Jobs::Revoked) —

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.

Parameters:

executor (Karafka::Processing::Executor)

Returns:

(Karafka::Processing::Jobs::Shutdown) —

shutdown job



23
24
25

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

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