Struct RatePolicy 

pub struct RatePolicy { /* private fields */ }

Per-kind rate sampler with deterministic, paired-event-safe decisions.

Unspecified kinds default to default_rate (initially 1.0, i.e. always sample). Configured kinds use the supplied rate in [0, 1], clamped to that range. Rates outside the unit interval are treated as the nearest valid value.

Sampling is computed by hashing the correlator with std::hash’s default hasher and comparing the bottom 32 bits, scaled to [0, 1), against the configured rate. Because event kind is deliberately not part of the bucket hash, paired emissions (e.g. tool.invoked and tool.completed sharing an internal call id) use the same bucket and are either both kept or both dropped when configured with the same rate.

Implementations

impl RatePolicy

pub fn new() -> Self

Build a policy that keeps every event (default_rate = 1.0) until rates are configured per-kind via with_rate.

pub fn with_default_rate(self, rate: f64) -> Self

Override the rate applied to event kinds that have no explicit entry. Useful when downsampling is the rule and full sampling is the exception.

pub fn with_rate(self, kind: impl Into<String>, rate: f64) -> Self

Set the sampling rate for kind to rate (clamped to [0, 1]).

kind should match an EventKind::discriminant() return value such as "tool.invoked", "tool.completed", "prompt.completed", "eval.report".

Trait Implementations

impl Clone for RatePolicy

fn clone(&self) -> RatePolicy

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for RatePolicy

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

Formats the value using the given formatter.

impl Default for RatePolicy

fn default() -> Self

Returns the “default value” for a type.

impl SamplingPolicy for RatePolicy

fn should_sample(&self, kind: &str, correlator: &str) -> bool

Return true if the event with the given kind discriminant (e.g. "tool.invoked", "prompt.completed") and per-emission correlator should be emitted.