Struct opentelemetry_tide::OpenTelemetryMetricsMiddleware

pub struct OpenTelemetryMetricsMiddleware { /* fields omitted */ }

The middleware struct to be used in tide

Implementations

impl OpenTelemetryMetricsMiddleware

pub fn new(config: MetricsConfig) -> Self

Instantiate the middleware

Examples

let mut app = tide::new();
app.with(opentelemetry_tide::OpenTelemetryMetricsMiddleware::new(None));
app.at("/").get(|_| async { Ok("Metricized!") });

with custom metrics configuration

let mut app = tide::new();
let mut config = opentelemetry_tide::MetricsConfig::default();
config.global_tags = Some(vec![opentelemetry::KeyValue::new("K","V")];)
app.with(opentelemetry_tide::OpenTelemetryMetricsMiddleware::new(Some(custom_kvs)));
app.at("/").get(|_| async { Ok("Metricized!") });

Trait Implementations

impl Debug for OpenTelemetryMetricsMiddleware

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

Formats the value using the given formatter.

impl Default for OpenTelemetryMetricsMiddleware

fn default() -> Self

Instantiate the middleware with defaults

Examples

let mut app = tide::new();
app.with(opentelemetry_tide::OpenTelemetryMetricsMiddleware::default());
app.at("/").get(|_| async { Ok("Metricized!") });

impl<State: Clone + Send + Sync + 'static> Middleware<State> for OpenTelemetryMetricsMiddleware

fn handle<'life0, 'life1, 'async_trait>(
    &'life0 self,
    req: Request<State>,
    next: Next<'life1, State>
) -> Pin<Box<dyn Future<Output = Result> + Send + 'async_trait>> where
    'life0: 'async_trait,
    'life1: 'async_trait,
    Self: 'async_trait, 

Asynchronously handle the request, and return a response.

fn name(&self) -> &str

Set the middleware’s name. By default it uses the type signature.