Sha256: 907a8c9f2f91ed1676a616414cd6a83e74806aca6ab644b7bcc3314ba825c6ca
Contents?: true
Size: 727 Bytes
Versions: 45
Compression:
Stored size: 727 Bytes
Contents
# frozen_string_literal: true
module WaterDrop
module Instrumentation
# WaterDrop 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
# @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 = WaterDrop::Instrumentation::Notifications.new,
namespace = nil
)
super(notifications_bus, namespace)
end
end
end
end
Version data entries
45 entries across 45 versions & 1 rubygems