Class: Karafka::Instrumentation::Monitor

Inherits:

Core::Monitoring::Monitor

Object
Core::Monitoring::Monitor
Karafka::Instrumentation::Monitor

show all

Defined in:: lib/karafka/instrumentation/monitor.rb

Overview

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

Instance Attribute Summary collapse

#notifications_bus ⇒ Object readonly
Returns the value of attribute notifications_bus.

Instance Method Summary collapse

#initialize(notifications_bus = Karafka::Instrumentation::Notifications.new, namespace = nil) ⇒ Monitor constructor
A new instance of Monitor.

Constructor Details

#initialize(notifications_bus = Karafka::Instrumentation::Notifications.new, namespace = nil) ⇒ `Monitor`

# File 'lib/karafka/instrumentation/monitor.rb', line 13

def initialize(
  notifications_bus = Karafka::Instrumentation::Notifications.new,
  namespace = nil
)
  super
end

Instance Attribute Details

#notifications_bus ⇒ `Object` (readonly)

Returns the value of attribute notifications_bus.



8
9
10

# File 'lib/karafka/instrumentation/monitor.rb', line 8

def notifications_bus
  @notifications_bus
end