Class: Karafka::Web::Processing::Consumers::Aggregators::State::Steps::Base

Inherits:

Object

• Object
• Karafka::Web::Processing::Consumers::Aggregators::State::Steps::Base

Defined in:

lib/karafka/web/processing/consumers/aggregators/state/steps/base.rb

Overview

Base class for all State pipeline steps.

Direct Known Subclasses

EvictExpiredProcesses, IncrementCounters, RefreshCurrentStats, RegisterProcess

Instance Method Summary

• #call ⇒ Object

  Executes the step, mutating context in place.

• #initialize(context) ⇒ Base constructor

  A new instance of Base.

Constructor Details

#initialize(context) ⇒ Base

Returns a new instance of Base.

Parameters:

• context (State::Context) —

  the shared context to enrich

# File 'lib/karafka/web/processing/consumers/aggregators/state/steps/base.rb', line 19

def initialize(context)
  @context = context
end

Instance Method Details

#call ⇒ Object

Executes the step, mutating context in place.

Subclasses must implement this method.

Raises:

• (NotImplementedError)

# File 'lib/karafka/web/processing/consumers/aggregators/state/steps/base.rb', line 26

def call
  raise NotImplementedError, "Implement this in a subclass"
end