class Semlogr::Sinks::Enriching

Public Class Methods

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

Public Instance Methods

emit(log_event) click to toggle source
# File lib/semlogr/sinks/enriching.rb, line 13
def emit(log_event)
  @enrichers.each do |enricher|
    begin
      enricher.enrich(log_event)
    rescue StandardError => e
      SelfLogger.error("Failed to enrich log event using enricher #{enricher.class}", e)
    end
  end

  @sink.emit(log_event)
end