class Datadog::Pipeline::SpanProcessor

SpanProcessor

Public Class Methods

new(operation = nil, &block) click to toggle source
# File lib/ddtrace/pipeline/span_processor.rb, line 5
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 13
def call(trace)
  trace.each do |span|
    @operation.call(span) rescue next
  end
end