Sha256: babcf7617282305dee058ef09ca1efded131eb039af1218186d297a379548f50
Contents?: true
Size: 1020 Bytes
Versions: 11
Compression:
Stored size: 1020 Bytes
Contents
# frozen_string_literal: true
module WaterDrop
module Instrumentation
# Instrumented is used to hookup external monitoring services to monitor how WaterDrop works
class Notifications < ::Karafka::Core::Monitoring::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
EVENTS.each { |event| register_event(event) }
end
end
end
end
Version data entries
11 entries across 11 versions & 1 rubygems