Class: Karafka::Instrumentation::Monitor

Inherits:
Core::Monitoring::Monitor
  • Object
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

Instance Method Summary collapse

Constructor Details

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

Returns a new instance of Monitor.

Parameters:

  • notifications_bus (Object) (defaults to: Karafka::Instrumentation::Notifications.new) —

    either our internal notifications bus or ActiveSupport::Notifications

  • namespace (String, nil) (defaults to: nil) —

    namespace for events or nil if no namespace



13
14
15
16
17
18
 
# 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