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 collapse

Class Method Details

.error_callbacks ⇒ Karafka::Core::Instrumentation::CallbacksManager

Builds a manager for error callbacks

Returns:



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

def error_callbacks
  @error_callbacks ||= CallbacksManager.new
end

.oauthbearer_token_refresh_callbacks ⇒ Karafka::Core::Instrumentation::CallbacksManager

Builds a manager for oauth bearer token refreshes

Returns:



22
23
24
 
# File 'lib/karafka/core/instrumentation.rb', line 22

def oauthbearer_token_refresh_callbacks
  @oauthbearer_token_refresh_callbacks ||= CallbacksManager.new
end

.statistics_callbacks ⇒ Karafka::Core::Instrumentation::CallbacksManager

Builds a manager for statistics callbacks

Returns:



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

def statistics_callbacks
  @statistics_callbacks ||= CallbacksManager.new
end