Class: Karafka::Processing::Jobs::Eofed

Inherits:

Base

• Object
• Base
• Karafka::Processing::Jobs::Eofed

Defined in:

lib/karafka/processing/jobs/eofed.rb

Overview

Job that runs the eofed operation when we receive eof without messages alongside.

Direct Known Subclasses

Karafka::Pro::Processing::Jobs::EofedNonBlocking

Instance Attribute Summary

Attributes inherited from Base

#executor

Instance Method Summary

• #before_schedule ⇒ Object

  Runs code prior to scheduling this eofed job.

• #call ⇒ Object

  Runs the eofed job via an executor.

• #initialize(executor) ⇒ Eofed constructor

Methods inherited from Base

#after_call, #before_call, #finish!, #finished?, #non_blocking?

Constructor Details

#initialize(executor) ⇒ Eofed

Parameters:

• executor (Karafka::Processing::Executor) —

  executor that is suppose to run the job

# File 'lib/karafka/processing/jobs/eofed.rb', line 10

def initialize(executor)
  @executor = executor
  super()
end

Instance Method Details

#before_schedule ⇒ Object

Runs code prior to scheduling this eofed job

# File 'lib/karafka/processing/jobs/eofed.rb', line 16

def before_schedule
  executor.before_schedule_eofed
end

#call ⇒ Object

Runs the eofed job via an executor.

# File 'lib/karafka/processing/jobs/eofed.rb', line 21

def call
  executor.eofed
end