Contents

module Semlogr
  module Sinks
    class Filtering
      def initialize(filters, sink)
        @filters = filters
        @sink = sink
      end

      def emit(log_event)
        filtered = @filters.any? { |filter| filter.call(log_event) }

        @sink.emit(log_event) unless filtered
      end
    end
  end
end

Version data entries

5 entries across 5 versions & 1 rubygems

Version	Path
semlogr-0.3.0	lib/semlogr/sinks/filtering.rb
semlogr-0.2.3	lib/semlogr/sinks/filtering.rb
semlogr-0.2.2	lib/semlogr/sinks/filtering.rb
semlogr-0.2.1	lib/semlogr/sinks/filtering.rb
semlogr-0.2.0	lib/semlogr/sinks/filtering.rb