Sha256: 1758b7ce585e79b804747bd830ec7312064fff74efd04f172d9ead6481ffedc1
Contents?: true
Size: 1.31 KB
Versions: 6
Compression:
Stored size: 1.31 KB
Contents
# frozen_string_literal: true
module WaterDrop
module Instrumentation
# Monitor is used to hookup external monitoring services to monitor how WaterDrop works
# Since it is a pub-sub based on dry-monitor, you can use as many subscribers/loggers at the
# same time, which means that you might have for example file logging and NewRelic at the same
# time
# @note This class acts as a singleton because we are only permitted to have single monitor
# per running process (just as logger)
class Monitor < Dry::Monitor::Notifications
# List of events that we support in the system and to which a monitor client can hook up
# @note The non-error once support timestamp benchmarking
EVENTS = %w[
producer.closed
message.produced_async
message.produced_sync
message.acknowledged
message.buffered
messages.produced_async
messages.produced_sync
messages.buffered
buffer.flushed_async
buffer.flushed_sync
statistics.emitted
error.occurred
].freeze
private_constant :EVENTS
# @return [WaterDrop::Instrumentation::Monitor] monitor instance for system instrumentation
def initialize
super(:waterdrop)
EVENTS.each(&method(:register_event))
end
end
end
end
Version data entries
6 entries across 6 versions & 1 rubygems