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.



268
269
270
 
# File 'lib/agent_harness/configuration.rb', line 268

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



286
287
288
289
290
291
292
 
# File 'lib/agent_harness/configuration.rb', line 286

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



277
278
279
 
# File 'lib/agent_harness/configuration.rb', line 277

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



298
299
300
 
# File 'lib/agent_harness/configuration.rb', line 298

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