Class: Semlogr::Sinks::Aggregate

Inherits:
Object
  • Object
show all
Defined in:
lib/semlogr/sinks/aggregate.rb

Instance Method Summary collapse

Constructor Details

#initialize(sinks) ⇒ Aggregate

Returns a new instance of Aggregate.


8
9
10
 
# File 'lib/semlogr/sinks/aggregate.rb', line 8

def initialize(sinks)
  @sinks = sinks
end

Instance Method Details

#emit(log_event) ⇒ Object 


12
13
14
15
16
17
18
19
20
 
# File 'lib/semlogr/sinks/aggregate.rb', line 12

def emit(log_event)
  @sinks.each do |sink|
    begin
      sink.emit(log_event)
    rescue StandardError => e
      SelfLogger.error("Failed to emit log event to sink #{sink.class}", e)
    end
  end
end