class Aspecto::OpenTelemetry::Sampler::RulesSampler
OpenTelemetry
sampler which implements the remote rules logic with fallback to service sampler
Public Class Methods
new(config, fallback_sampler, service_name, env)
click to toggle source
# File lib/aspecto/opentelemetry/sampler/rules_sampler.rb, line 12 def initialize(config, fallback_sampler, service_name, env) @rules = config .select { |rule| Operator.new(rule["packageName"]["comparison"], rule["packageName"]["value"]).satisfies?(service_name) } .select { |rule| Operator.new(rule["env"]["comparison"], rule["env"]["value"]).satisfies?(env) } .map { |rule_config| SamplingRule.new rule_config } @fallback_sampler = fallback_sampler end
Public Instance Methods
description()
click to toggle source
# File lib/aspecto/opentelemetry/sampler/rules_sampler.rb, line 26 def description "RulesSampler {#{rules.length} rules}" end
matching_rule(name:, attributes:)
click to toggle source
# File lib/aspecto/opentelemetry/sampler/rules_sampler.rb, line 30 def matching_rule(name:, attributes:) @rules.find { |rule| rule.satisfies?(attributes, name) } end
should_sample?(trace_id:, parent_context:, links:, name:, kind:, attributes:)
click to toggle source
# File lib/aspecto/opentelemetry/sampler/rules_sampler.rb, line 20 def should_sample?(trace_id:, parent_context:, links:, name:, kind:, attributes:) rule = matching_rule(name: name, attributes: attributes) delegate_sampler = rule ? rule.sampler : @fallback_sampler delegate_sampler.should_sample?(trace_id: trace_id, parent_context: parent_context, links: links, name: name, kind: kind, attributes: attributes) end