Struct opentelemetry_surf::OpenTelemetryTracingMiddleware

pub struct OpenTelemetryTracingMiddleware { /* private fields */ }

The middleware struct to be used in surf

Implementations

impl OpenTelemetryTracingMiddleware

pub fn new(tracer: BoxedTracer) -> Self

Instantiate the middleware

Examples

let _tracer = opentelemetry_jaeger::new_pipeline().install_batch(opentelemetry::runtime::AsyncStd)?;
let tracer = global::tracer("my-client");
let otel_mw = opentelemetry_surf::OpenTelemetryTracingMiddleware::new(tracer);
let client = surf::client().with(otel_mw);
let res = client.get("https://httpbin.org/get").await?;
dbg!(res);
Ok(())

pub fn new_from_global() -> Self

Instantiate the middleware with the global tracer

Examples

let _tracer = opentelemetry_jaeger::new_pipeline().install_batch(opentelemetry::runtime::AsyncStd)?;
let otel_mw = opentelemetry_surf::OpenTelemetryTracingMiddleware::new_from_global();
let client = surf::client().with(otel_mw);
let res = client.get("https://httpbin.org/get").await?;
dbg!(res);
Ok(())

Trait Implementations

impl Debug for OpenTelemetryTracingMiddleware

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

Formats the value using the given formatter.

impl Default for OpenTelemetryTracingMiddleware

fn default() -> Self

Instantiate the middleware with the global tracer as default; see OpenTelemetryTracingMiddleware::new_from_global for details/example.

impl Middleware for OpenTelemetryTracingMiddleware

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

Asynchronously handle the request, and return a response.