Struct SamplingEvaluator

pub struct SamplingEvaluator<'a> { /* private fields */ }

State machine for dynamic sampling.

Implementations

impl<'a> SamplingEvaluator<'a>

pub fn new_with_reservoir( now: DateTime<Utc>, reservoir: &'a ReservoirEvaluator<'a>, ) -> Self

Constructs an evaluator with reservoir sampling.

pub fn new(now: DateTime<Utc>) -> Self

Constructs an evaluator without reservoir sampling.

pub async fn match_rules<'b, I, G>( self, seed: Uuid, instance: &G, rules: I, ) -> ControlFlow<SamplingMatch, Self>

where G: Getter, I: Iterator<Item = &'b SamplingRule>,

Attempts to find a match for sampling rules using ControlFlow.

This function returns a ControlFlow to provide control over the matching process.

• ControlFlow::Continue: Indicates that matching is incomplete, and more rules can be evaluated.

  • This state occurs either if no active rules match the provided data, or if the matched rules are factors requiring a final sampling value.
  • The returned evaluator contains the state of the matched rules and the accumulated sampling factor.
  • If this value is returned and there are no more rules to evaluate, it should be interpreted as “no match.”

• ControlFlow::Break: Indicates that one or more rules have successfully matched.

Trait Implementations

impl<'a> Debug for SamplingEvaluator<'a>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.