Sha256: e96d416f44ed87bac089d6bcb29303e362e62f234be88d0990c87aabb83e4227
Contents?: true
Size: 587 Bytes
Versions: 24
Compression:
Stored size: 587 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 [WaterDrop::CallbacksManager]
def statistics_callbacks
@statistics_callbacks ||= CallbacksManager.new
end
# Builds a manager for error callbacks
# @return [WaterDrop::CallbacksManager]
def error_callbacks
@error_callbacks ||= CallbacksManager.new
end
end
end
end
end
Version data entries
24 entries across 24 versions & 1 rubygems