Class: AgentHarness::CallbackRegistry

Inherits:
Object
  • Object
show all
Defined in:
lib/agent_harness/configuration.rb

Overview

Registry for event callbacks

Instance Method Summary collapse

Constructor Details

#initialize ⇒ CallbackRegistry

Returns a new instance of CallbackRegistry.



421
422
423
 
# File 'lib/agent_harness/configuration.rb', line 421

def initialize
  @callbacks = Hash.new { |h, k| h[k] = [] }
end

Instance Method Details

#emit(event, data) ⇒ void

This method returns an undefined value.

Emit an event to all registered callbacks

Parameters:

  • event (Symbol) —

    the event name

  • data (Hash) —

    event data



439
440
441
442
443
444
445
 
# File 'lib/agent_harness/configuration.rb', line 439

def emit(event, data)
  @callbacks[event].each do |callback|
    callback.call(data)
  rescue => e
    AgentHarness.logger&.error("[AgentHarness::CallbackRegistry] Callback error for #{event}: #{e.message}")
  end
end

#register(event, block) ⇒ void

This method returns an undefined value.

Register a callback for an event

Parameters:

  • event (Symbol) —

    the event name

  • block (Proc) —

    the callback



430
431
432
 
# File 'lib/agent_harness/configuration.rb', line 430

def register(event, block)
  @callbacks[event] << block
end

#registered?(event) ⇒ Boolean

Check if any callbacks are registered for an event

Parameters:

  • event (Symbol) —

    the event name

Returns:

  • (Boolean) —

    true if callbacks exist



451
452
453
 
# File 'lib/agent_harness/configuration.rb', line 451

def registered?(event)
  @callbacks[event].any?
end