Class: Jaeger::Samplers::GuaranteedThroughputProbabilistic
- Inherits:
-
Object
- Object
- Jaeger::Samplers::GuaranteedThroughputProbabilistic
- Defined in:
- lib/jaeger/samplers/guaranteed_throughput_probabilistic.rb
Overview
A sampler that leverages both Probabilistic sampler and RateLimiting sampler. The RateLimiting is used as a guaranteed lower bound sampler such that every operation is sampled at least once in a time interval defined by the lower_bound. ie a lower_bound of 1.0 / (60 * 10) will sample an operation at least once every 10 minutes.
The Probabilistic sampler is given higher priority when tags are emitted, ie. if is_sampled() for both samplers return true, the tags for Probabilistic sampler will be used.
Instance Attribute Summary collapse
-
#tags ⇒ Object
readonly
Returns the value of attribute tags.
Instance Method Summary collapse
-
#initialize(lower_bound:, rate:, lower_bound_sampler: nil) ⇒ GuaranteedThroughputProbabilistic
constructor
A new instance of GuaranteedThroughputProbabilistic.
- #sample?(*args) ⇒ Boolean
Constructor Details
#initialize(lower_bound:, rate:, lower_bound_sampler: nil) ⇒ GuaranteedThroughputProbabilistic
Returns a new instance of GuaranteedThroughputProbabilistic.
17 18 19 20 21 22 23 24 |
# File 'lib/jaeger/samplers/guaranteed_throughput_probabilistic.rb', line 17 def initialize(lower_bound:, rate:, lower_bound_sampler: nil) @probabilistic_sampler = Probabilistic.new(rate: rate) @lower_bound_sampler = lower_bound_sampler || RateLimiting.new(max_traces_per_second: lower_bound) @lower_bound_tags = { 'sampler.type' => 'lowerbound', 'sampler.param' => lower_bound } end |
Instance Attribute Details
#tags ⇒ Object (readonly)
Returns the value of attribute tags.
15 16 17 |
# File 'lib/jaeger/samplers/guaranteed_throughput_probabilistic.rb', line 15 def @tags end |
Instance Method Details
#sample?(*args) ⇒ Boolean
26 27 28 29 30 31 32 33 34 35 36 37 |
# File 'lib/jaeger/samplers/guaranteed_throughput_probabilistic.rb', line 26 def sample?(*args) is_sampled, = @probabilistic_sampler.sample?(*args) if is_sampled # We still call lower_bound_sampler to update the rate limiter budget @lower_bound_sampler.sample?(*args) return [is_sampled, ] end is_sampled, = @lower_bound_sampler.sample?(*args) [is_sampled, @lower_bound_tags] end |