Sha256: 33f962b4196acb949eec51099f7916c258f452161e20787b26aa6ccf4841d7b7
Contents?: true
Size: 761 Bytes
Versions: 102
Compression:
Stored size: 761 Bytes
Contents
# frozen_string_literal: true
module Karafka
module Instrumentation
# Karafka instrumentation monitor that we use to publish events
# By default uses our internal notifications bus but can be used with
# `ActiveSupport::Notifications` as well
class Monitor < ::Karafka::Core::Monitoring::Monitor
attr_reader :notifications_bus
# @param notifications_bus [Object] either our internal notifications bus or
# `ActiveSupport::Notifications`
# @param namespace [String, nil] namespace for events or nil if no namespace
def initialize(
notifications_bus = ::Karafka::Instrumentation::Notifications.new,
namespace = nil
)
super(notifications_bus, namespace)
end
end
end
end
Version data entries
102 entries across 102 versions & 1 rubygems