Struct TelemetryFilter

pub struct TelemetryFilter { /* private fields */ }

Available on crate features config and config-observability only.

Structure to define ProSA telemetry filter

use prosa_utils::config::observability::Observability;
use prosa_utils::config::tracing::TelemetryFilter;
use prosa_utils::config::tracing;
use tracing_subscriber::filter;

// Create telemetry filter with a DEBUG level
let mut telemetry_filter = TelemetryFilter::new(filter::LevelFilter::DEBUG);

// Specific processor log level shouldn't be greater than the global telemetry filter level
telemetry_filter.add_proc_filter(String::from("prosa_test_proc"), filter::LevelFilter::INFO);

let otel_settings = Observability::default();
otel_settings.tracing_init(&telemetry_filter);

Implementations

impl TelemetryFilter

pub fn new(level: LevelFilter) -> TelemetryFilter

Method to create a new telemetry filter

pub fn clone_with_level(&self, level: TelemetryLevel) -> TelemetryFilter

Method to clone the telemetry filter and change its default level if it’s less verbose

pub fn add_proc_filter(&mut self, proc_name: String, level: LevelFilter)

Method to add a filter on a specific processor

Trait Implementations

impl Clone for TelemetryFilter

fn clone(&self) -> TelemetryFilter

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for TelemetryFilter

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

Formats the value using the given formatter.

impl Default for TelemetryFilter

fn default() -> TelemetryFilter

Returns the “default value” for a type.

impl<S> Filter<S> for TelemetryFilter

fn enabled(&self, metadata: &Metadata<'_>, _: &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 callsite_enabled(&self, metadata: &'static Metadata<'static>) -> Interest

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

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

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

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.