Sha256: 004f48600116ae5e2ea49a745ef90262e9f7ec15df08bb1367649a386fdf434f
Contents?: true
Size: 891 Bytes
Versions: 14
Compression:
Stored size: 891 Bytes
Contents
# frozen_string_literal: true
module Karafka
module Core
# All the instrumentation shared across Karafka ecosystem
module Instrumentation
class << self
# Builds a manager for statistics callbacks
# @return [Karafka::Core::Instrumentation::CallbacksManager]
def statistics_callbacks
@statistics_callbacks ||= CallbacksManager.new
end
# Builds a manager for error callbacks
# @return [Karafka::Core::Instrumentation::CallbacksManager]
def error_callbacks
@error_callbacks ||= CallbacksManager.new
end
# Builds a manager for oauth bearer token refreshes
# @return [Karafka::Core::Instrumentation::CallbacksManager]
def oauthbearer_token_refresh_callbacks
@oauthbearer_token_refresh_callbacks ||= CallbacksManager.new
end
end
end
end
end
Version data entries
14 entries across 14 versions & 1 rubygems