Contents

# frozen_string_literal: true

# Copyright The OpenTelemetry Authors
#
# SPDX-License-Identifier: Apache-2.0

module OpenTelemetry
  module SDK
    module Trace
      module Samplers
        # @api private
        #
        # The ParentConsistentProbabilityBased sampler is meant as an optional
        # replacement for the ParentBased sampler. It is required to first validate
        # the tracestate and then respect the sampled flag in the W3C traceparent.
        #
        # The ParentConsistentProbabilityBased Sampler constructor takes a single
        # Sampler argument, which is the Sampler to use in case the
        # ParentConsistentProbabilityBased Sampler is called for a root span.
        class ParentConsistentProbabilityBased
          include ConsistentProbabilityTraceState

          def initialize(root)
            @root = root
          end

          def ==(other)
            @root == other.root
          end

          # @api private
          #
          # See {Samplers}.
          def description
            "ParentConsistentProbabilityBased{root=#{@root.description}}"
          end

          # @api private
          #
          # See {Samplers}.
          def should_sample?(trace_id:, parent_context:, links:, name:, kind:, attributes:)
            parent_span_context = OpenTelemetry::Trace.current_span(parent_context).context
            if !parent_span_context.valid?
              @root.should_sample?(trace_id: trace_id, parent_context: parent_context, links: links, name: name, kind: kind, attributes: attributes)
            else
              tracestate = sanitized_tracestate(trace_id, parent_span_context)
              if parent_span_context.trace_flags.sampled?
                Result.new(decision: Decision::RECORD_AND_SAMPLE, tracestate: tracestate)
              else
                Result.new(decision: Decision::DROP, tracestate: tracestate)
              end
            end
          end

          protected

          attr_reader :root
        end
      end
    end
  end
end

Version data entries

4 entries across 4 versions & 1 rubygems

Version	Path
opentelemetry-sdk-experimental-0.3.2	lib/opentelemetry/sdk/trace/samplers/parent_consistent_probability_based.rb
opentelemetry-sdk-experimental-0.3.1	lib/opentelemetry/sdk/trace/samplers/parent_consistent_probability_based.rb
opentelemetry-sdk-experimental-0.3.0	lib/opentelemetry/sdk/trace/samplers/parent_consistent_probability_based.rb
opentelemetry-sdk-experimental-0.2.0	lib/opentelemetry/sdk/trace/samplers/parent_consistent_probability_based.rb