Sha256: da4342d2ac84faaf4cdcffbcac268a220c6aa342a0fb09cf954db7b25a958ef8
Contents?: true
Size: 997 Bytes
Versions: 8
Compression:
Stored size: 997 Bytes
Contents
module Datadog
# Pipeline
module Pipeline
require_relative 'pipeline/span_filter'
require_relative 'pipeline/span_processor'
@mutex = Mutex.new
@processors = []
def self.before_flush(*processors, &processor_block)
processors = [processor_block] if processors.empty?
@mutex.synchronize do
@processors.concat(processors)
end
end
def self.process!(traces)
@mutex.synchronize do
traces
.map(&method(:apply_processors!))
.select(&:any?)
end
end
def self.processors=(value)
@processors = value
end
def self.apply_processors!(trace)
result = @processors.inject(trace) do |current_trace, processor|
processor.call(current_trace)
end
result || []
rescue => e
Datadog::Logger.log.debug(
"trace dropped entirely due to `Pipeline.before_flush` error: #{e}"
)
[]
end
private_class_method :apply_processors!
end
end
Version data entries
8 entries across 8 versions & 1 rubygems