Sha256: b6d35336f61c929d7c2aa03e00bb01879307216124aef61820ac5575d869d6eb

Contents?: true

Size: 413 Bytes

Versions: 94

Compression:

Stored size: 413 Bytes

Contents

module Datadog
  module Pipeline
    # SpanProcessor
    class SpanProcessor
      def initialize(operation = nil, &block)
        callable = operation || block

        raise(ArgumentError) unless callable.respond_to?(:call)

        @operation = operation || block
      end

      def call(trace)
        trace.each do |span|
          @operation.call(span) rescue next
        end
      end
    end
  end
end

Version data entries

94 entries across 94 versions & 2 rubygems

Version Path
ddtrace-0.17.0 lib/ddtrace/pipeline/span_processor.rb
ddtrace-0.16.1 lib/ddtrace/pipeline/span_processor.rb
ddtrace-0.15.0.internaltracinfeature1 lib/ddtrace/pipeline/span_processor.rb
ddtrace-0.16.0 lib/ddtrace/pipeline/span_processor.rb
ddtrace-0.14.2.disableprotocolversion4 lib/ddtrace/pipeline/span_processor.rb
ddtrace-0.15.0 lib/ddtrace/pipeline/span_processor.rb
ddtrace-0.14.2.withoutpriorityparsing1 lib/ddtrace/pipeline/span_processor.rb
ddtrace-0.14.2 lib/ddtrace/pipeline/span_processor.rb
ddtrace-0.14.1 lib/ddtrace/pipeline/span_processor.rb
ddtrace-0.15.0.beta1 lib/ddtrace/pipeline/span_processor.rb
ddtrace-0.14.0 lib/ddtrace/pipeline/span_processor.rb
ddtrace-0.14.0.rc1 lib/ddtrace/pipeline/span_processor.rb
ddtrace-0.13.2 lib/ddtrace/pipeline/span_processor.rb
ddtrace-0.14.0.beta2 lib/ddtrace/pipeline/span_processor.rb
ddtrace-0.14.0.beta1 lib/ddtrace/pipeline/span_processor.rb
ddtrace-0.13.1 lib/ddtrace/pipeline/span_processor.rb
ddtrace-0.13.0 lib/ddtrace/pipeline/span_processor.rb
ddtrace-0.12.1 lib/ddtrace/pipeline/span_processor.rb
ddtrace-0.13.0.beta1 lib/ddtrace/pipeline/span_processor.rb
ddtrace-0.12.0 lib/ddtrace/pipeline/span_processor.rb