class Datadog::Pipeline::SpanProcessor
Public Class Methods
new(operation = nil, &block)
click to toggle source
# File lib/ddtrace/pipeline/span_processor.rb, line 6 def initialize(operation = nil, &block) callable = operation || block raise(ArgumentError) unless callable.respond_to?(:call) @operation = operation || block end
Public Instance Methods
call(trace)
click to toggle source
# File lib/ddtrace/pipeline/span_processor.rb, line 14 def call(trace) trace.each do |span| @operation.call(span) rescue next end end