Class: WaterDrop::Instrumentation::Notifications

Inherits:

Karafka::Core::Monitoring::Notifications

• Object
• Karafka::Core::Monitoring::Notifications
• WaterDrop::Instrumentation::Notifications

Defined in:

lib/waterdrop/instrumentation/notifications.rb

Overview

Instrumented is used to hookup external monitoring services to monitor how WaterDrop works

Constant Summary

EVENTS =

Note:

The non-error once support timestamp benchmarking

List of events that we support in the system and to which a monitor client can hook up

%w[
  producer.connected
  producer.closing
  producer.closed

  message.produced_async
  message.produced_sync
  message.acknowledged
  message.purged
  message.buffered

  messages.produced_async
  messages.produced_sync
  messages.buffered

  oauthbearer.token_refresh

  transaction.started
  transaction.committed
  transaction.aborted
  transaction.marked_as_consumed
  transaction.finished

  buffer.flushed_async
  buffer.flushed_sync
  buffer.purged

  statistics.emitted

  error.occurred
].freeze

Instance Method Summary

• #initialize ⇒ WaterDrop::Instrumentation::Monitor constructor

  Monitor instance for system instrumentation.

Constructor Details

#initialize ⇒ WaterDrop::Instrumentation::Monitor

Returns monitor instance for system instrumentation.

# File 'lib/waterdrop/instrumentation/notifications.rb', line 42

def initialize
  super
  EVENTS.each { |event| register_event(event) }
end