Sha256: bf364a5207ae647a4ad438921f5b74206b00445303263a8f6dafdde3db9b0574

Contents?: true

Size: 768 Bytes

Versions: 3

Compression:

Stored size: 768 Bytes

Contents

require 'ddtrace/context_flush'

module Datadog
  module CI
    module ContextFlush
      # Common behavior for CI flushing
      module Tagging
        # Decorate a trace with CI tags
        def get_trace(context)
          context.get do |trace|
            # Origin tag is required on every span
            trace.each { |span| context.attach_origin(span) } if trace
          end
        end
      end

      # Consumes only completed traces (where all spans have finished)
      class Finished < Datadog::ContextFlush::Finished
        prepend Tagging
      end

      # Performs partial trace flushing to avoid large traces residing in memory for too long
      class Partial < Datadog::ContextFlush::Partial
        prepend Tagging
      end
    end
  end
end

Version data entries

3 entries across 3 versions & 1 rubygems

Version Path
ddtrace-0.51.1 lib/datadog/ci/context_flush.rb
ddtrace-0.51.0 lib/datadog/ci/context_flush.rb
ddtrace-0.50.0 lib/datadog/ci/context_flush.rb