class Semlogr::Sinks::Aggregate

Public Class Methods

new(sinks) click to toggle source
# File lib/semlogr/sinks/aggregate.rb, line 8
def initialize(sinks)
  @sinks = sinks
end

Public Instance Methods

emit(log_event) click to toggle source
# 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