Sha256: fc21cccb34cd319c5c444a82c1b49d5d00ed376a310939f5d8c4901d7122c2c9
Contents?: true
Size: 939 Bytes
Versions: 8
Compression:
Stored size: 939 Bytes
Contents
# frozen_string_literal: true
require_relative '../tracing/metadata/ext'
require_relative '../tracing/flush'
module Datadog
module CI
module Flush
# Common behavior for CI flushing
module Tagging
# Decorate a trace with CI tags
def get_trace(trace_op)
trace = trace_op.flush!
# Origin tag is required on every span
trace.spans.each do |span|
span.set_tag(
Tracing::Metadata::Ext::Distributed::TAG_ORIGIN,
trace.origin
)
end
trace
end
end
# Consumes only completed traces (where all spans have finished)
class Finished < Tracing::Flush::Finished
prepend Tagging
end
# Performs partial trace flushing to avoid large traces residing in memory for too long
class Partial < Tracing::Flush::Partial
prepend Tagging
end
end
end
end
Version data entries
8 entries across 8 versions & 1 rubygems