Class: Karafka::Pro::Processing::ConsumerGroups::Jobs::Periodic

Inherits:

Karafka::Processing::Jobs::Base

• Object
• Karafka::Processing::Jobs::Base
• Karafka::Pro::Processing::ConsumerGroups::Jobs::Periodic

Defined in:

lib/karafka/pro/processing/consumer_groups/jobs/periodic.rb

Overview

Job that represents a "ticking" work. Work that we run periodically for the Periodics enabled topics.

Direct Known Subclasses

PeriodicNonBlocking

Instance Attribute Summary

Attributes inherited from Karafka::Processing::Jobs::Base

#executor

Instance Method Summary

• #before_schedule ⇒ Object

  Code executed before we schedule this job.

• #call ⇒ Object

  Runs the executor periodic action.

• #initialize(executor) ⇒ Periodic constructor

  A new instance of Periodic.

Methods inherited from Karafka::Processing::Jobs::Base

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

Constructor Details

#initialize(executor) ⇒ Periodic

Returns a new instance of Periodic.

Parameters:

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

  pro executor that is suppose to run a given job

# File 'lib/karafka/pro/processing/consumer_groups/jobs/periodic.rb', line 44

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

Instance Method Details

#before_schedule ⇒ Object

Code executed before we schedule this job

# File 'lib/karafka/pro/processing/consumer_groups/jobs/periodic.rb', line 50

def before_schedule
  executor.before_schedule_periodic
end

#call ⇒ Object

Runs the executor periodic action

# File 'lib/karafka/pro/processing/consumer_groups/jobs/periodic.rb', line 55

def call
  executor.periodic
end