Struct OpenTelemetryRateLimitingFilter 

pub struct OpenTelemetryRateLimitingFilter {
    backoff_duration: Duration,
    last_logged: Mutex<BTreeMap<u64, EpochMillis>>,
    suppressed_count: AtomicU64,
    now_fn: NowFn,
}

Available on crate feature tracing only.

A rate-limiting filter that throttles OpenTelemetry internal log messages.

OpenTelemetry can emit a large number of duplicate error messages (e.g., when the batch processor channel is full or when there are connection issues). This filter rate-limits these messages to avoid log spam while still ensuring the errors are visible.

Only logs from OpenTelemetry targets (those starting with “opentelemetry”) are rate-limited. All other logs pass through unchanged.

Fields

backoff_duration: Duration

How long to suppress duplicate messages from OpenTelemetry.

last_logged: Mutex<BTreeMap<u64, EpochMillis>>

Tracks the last time each unique message key was logged. The key is a hash of (target, message format string).

suppressed_count: AtomicU64

Counter for the number of suppressed messages.

now_fn: NowFn

Function to get the current time (helps with testing).

Implementations

impl OpenTelemetryRateLimitingFilter

pub fn new(backoff_duration: Duration) -> Self

Creates a new rate-limiting filter with the specified backoff duration.

Messages from OpenTelemetry targets will be suppressed if they occur more frequently than once per backoff_duration.

fn compute_key(metadata: &Metadata<'_>) -> u64

Computes a hash key for the given event metadata.

fn should_log(&self, metadata: &Metadata<'_>) -> bool

Returns true if the event should be logged (not rate-limited).

pub fn suppressed_count(&self) -> u64

Returns the number of messages that have been suppressed.

Trait Implementations

impl Debug for OpenTelemetryRateLimitingFilter

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

Formats the value using the given formatter.

impl<S> Filter<S> for OpenTelemetryRateLimitingFilter

where S: Subscriber + for<'lookup> LookupSpan<'lookup>,

fn enabled(&self, metadata: &Metadata<'_>, _ctx: &Context<'_, S>) -> bool

Returns true if this layer is interested in a span or event with the given Metadata in the current Context, similarly to Subscriber::enabled.

fn event_enabled(&self, event: &Event<'_>, _ctx: &Context<'_, S>) -> bool

Called before the filtered [Layer]'s [on_event], to determine if on_event` should be called.

fn callsite_enabled(&self, meta: &'static Metadata<'static>) -> Interest

Returns an Interest indicating whether this layer will always, sometimes, or never be interested in the given Metadata.

fn max_level_hint(&self) -> Option<LevelFilter>

Returns an optional hint of the highest verbosity level that this Filter will enable.

fn on_new_span(&self, attrs: &Attributes<'_>, id: &Id, ctx: Context<'_, S>)

Notifies this filter that a new span was constructed with the given Attributes and Id.

fn on_record(&self, id: &Id, values: &Record<'_>, ctx: Context<'_, S>)

Notifies this filter that a span with the given Id recorded the given values.

fn on_enter(&self, id: &Id, ctx: Context<'_, S>)

Notifies this filter that a span with the given ID was entered.

fn on_exit(&self, id: &Id, ctx: Context<'_, S>)

Notifies this filter that a span with the given ID was exited.

fn on_close(&self, id: Id, ctx: Context<'_, S>)

Notifies this filter that a span with the given ID has been closed.