Module: Karafka::Core::Instrumentation

Defined in:

lib/karafka/core/instrumentation.rb,
lib/karafka/core/instrumentation/callbacks_manager.rb

Overview

Karafka instrumentation related shared components

Defined Under Namespace

Classes: CallbacksManager

Class Method Summary

• .error_callbacks ⇒ WaterDrop::CallbacksManager

  Builds a manager for error callbacks.

• .statistics_callbacks ⇒ WaterDrop::CallbacksManager

  Builds a manager for statistics callbacks.

Class Method Details

.error_callbacks ⇒ WaterDrop::CallbacksManager

Builds a manager for error callbacks

Returns:

• (WaterDrop::CallbacksManager)

# File 'lib/karafka/core/instrumentation.rb', line 16

def error_callbacks
  @error_callbacks ||= CallbacksManager.new
end

.statistics_callbacks ⇒ WaterDrop::CallbacksManager

Builds a manager for statistics callbacks

Returns:

• (WaterDrop::CallbacksManager)

# File 'lib/karafka/core/instrumentation.rb', line 10

def statistics_callbacks
  @statistics_callbacks ||= CallbacksManager.new
end