pub struct FilteredOpenTelemetryLayer<S, T, F> { /* private fields */ }Expand description
A layer wrapping a OpenTelemetryLayer, discarding all events filtered out by a given
Filter. This can be built by calling OpenTelemetryLayer::with_counting_event_filter.
Only events that are not filtered out will be saved as events on the span. All events, including
those filtered out, will be counted and the total will be provided in the
otel.tracing_event_count field of the exported span.
This is useful when there is large volume of logs outputted by the application and it would be too expensive to export all of them as span events, but it is still desirable to have information whether there is more information in logs for the given span.
Implementations§
Source§impl<S, T, F> FilteredOpenTelemetryLayer<S, T, F>
impl<S, T, F> FilteredOpenTelemetryLayer<S, T, F>
pub fn map_inner<Mapper, S2, T2>( self, mapper: Mapper, ) -> FilteredOpenTelemetryLayer<S2, T2, F>
pub fn with_counting_event_filter<F2>(
self,
filter: F2,
) -> FilteredOpenTelemetryLayer<S, T, F2>where
F2: Filter<S>,
Trait Implementations§
Source§impl<S, T, F> Layer<S> for FilteredOpenTelemetryLayer<S, T, F>where
S: Subscriber + for<'lookup> LookupSpan<'lookup>,
OpenTelemetryLayer<S, T>: Layer<S>,
F: Filter<S> + 'static,
impl<S, T, F> Layer<S> for FilteredOpenTelemetryLayer<S, T, F>where
S: Subscriber + for<'lookup> LookupSpan<'lookup>,
OpenTelemetryLayer<S, T>: Layer<S>,
F: Filter<S> + 'static,
Source§fn register_callsite(&self, metadata: &'static Metadata<'static>) -> Interest
fn register_callsite(&self, metadata: &'static Metadata<'static>) -> Interest
Registers a new callsite with this layer, returning whether or not
the layer is interested in being notified about the callsite, similarly
to
Subscriber::register_callsite. Read moreSource§fn enabled(&self, metadata: &Metadata<'_>, ctx: Context<'_, S>) -> bool
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. Read moreSource§fn on_new_span(&self, attrs: &Attributes<'_>, id: &Id, ctx: Context<'_, S>)
fn on_new_span(&self, attrs: &Attributes<'_>, id: &Id, ctx: Context<'_, S>)
Notifies this layer that a new span was constructed with the given
Attributes and Id.Source§fn on_record(&self, span: &Id, values: &Record<'_>, ctx: Context<'_, S>)
fn on_record(&self, span: &Id, values: &Record<'_>, ctx: Context<'_, S>)
Notifies this layer that a span with the given
Id recorded the given
values.Source§fn on_follows_from(&self, span: &Id, follows: &Id, ctx: Context<'_, S>)
fn on_follows_from(&self, span: &Id, follows: &Id, ctx: Context<'_, S>)
Notifies this layer that a span with the ID
span recorded that it
follows from the span with the ID follows.Source§fn on_event(&self, event: &Event<'_>, ctx: Context<'_, S>)
fn on_event(&self, event: &Event<'_>, ctx: Context<'_, S>)
Notifies this layer that an event has occurred.
Source§fn on_enter(&self, id: &Id, ctx: Context<'_, S>)
fn on_enter(&self, id: &Id, ctx: Context<'_, S>)
Notifies this layer that a span with the given ID was entered.
Source§fn on_exit(&self, id: &Id, ctx: Context<'_, S>)
fn on_exit(&self, id: &Id, ctx: Context<'_, S>)
Notifies this layer that the span with the given ID was exited.
Source§fn on_close(&self, id: Id, ctx: Context<'_, S>)
fn on_close(&self, id: Id, ctx: Context<'_, S>)
Notifies this layer that the span with the given ID has been closed.
Source§fn on_id_change(&self, old: &Id, new: &Id, ctx: Context<'_, S>)
fn on_id_change(&self, old: &Id, new: &Id, ctx: Context<'_, S>)
Notifies this layer that a span ID has been cloned, and that the
subscriber returned a different ID.
Source§fn on_register_dispatch(&self, subscriber: &Dispatch)
fn on_register_dispatch(&self, subscriber: &Dispatch)
Performs late initialization when installing this layer as a
Subscriber. Read moreSource§fn and_then<L>(self, layer: L) -> Layered<L, Self, S>
fn and_then<L>(self, layer: L) -> Layered<L, Self, S>
Composes this layer around the given
Layer, returning a Layered
struct implementing Layer. Read moreSource§fn with_subscriber(self, inner: S) -> Layered<Self, S>where
Self: Sized,
fn with_subscriber(self, inner: S) -> Layered<Self, S>where
Self: Sized,
Composes this
Layer with the given Subscriber, returning a
Layered struct that implements Subscriber. Read moreSource§fn with_filter<F>(self, filter: F) -> Filtered<Self, F, S>
fn with_filter<F>(self, filter: F) -> Filtered<Self, F, S>
Available on crate features
registry and std only.Auto Trait Implementations§
impl<S, T, F> Freeze for FilteredOpenTelemetryLayer<S, T, F>
impl<S, T, F> RefUnwindSafe for FilteredOpenTelemetryLayer<S, T, F>
impl<S, T, F> Send for FilteredOpenTelemetryLayer<S, T, F>
impl<S, T, F> Sync for FilteredOpenTelemetryLayer<S, T, F>
impl<S, T, F> Unpin for FilteredOpenTelemetryLayer<S, T, F>
impl<S, T, F> UnwindSafe for FilteredOpenTelemetryLayer<S, T, F>
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more