Struct MkSpanExecutor 

pub struct MkSpanExecutor<E, F> { /* private fields */ }

Available on crate feature tracing only.

An executor that uses a callback to propagate tracing span to its futures.

The callback is invoked each time a future is spawned, creating a span that will be entered each time that future is polled or dropped. Execution is delegated to the wrapped executor, without requiring a particular runtime.

Requires the tracing feature.

Example

Spawned tasks can be marked as “following from” the execution context.

See tracing::Span::follows_from() for more information about indicating causal relationships between spans.

use hyper_util::rt::{MkSpanExecutor, TokioExecutor};
use tracing::{info_span, Span};

let mk = || {
    let span = info_span!("example");
    span.follows_from(Span::current());
    span
};
let executor = MkSpanExecutor::new(TokioExecutor::new(), mk);

Spawned tasks can be marked as children of the execution context.

use hyper_util::rt::{MkSpanExecutor, TokioExecutor};
use tracing::{info_span, Span};

let mk = || info_span!(parent: Span::current(), "example");
let executor = MkSpanExecutor::new(TokioExecutor::new(), mk);

Implementations

impl<E, F> MkSpanExecutor<E, F>

pub fn new(inner: E, mk: F) -> Self

Wrap an executor that creates new spans to instrument spawned futures.

Trait Implementations

impl<E: Clone, F: Clone> Clone for MkSpanExecutor<E, F>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<E: Debug, F: Debug> Debug for MkSpanExecutor<E, F>

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

Formats the value using the given formatter.

impl<E, F, Fut> Executor<Fut> for MkSpanExecutor<E, F>

where E: Executor<Instrumented<Fut>>, F: Fn() -> Span, Fut: Future,

fn execute(&self, future: Fut)

Place the future into the executor to be run.