Struct observability::MsgWrap

pub struct MsgWrap<T> { /* fields omitted */ }

Wrap a channel message in a span context. The context is automatically propagated to the current span by calling msg_wrap.inner(). The context is automatically propagated from the current span by calling t.into(). If you wish to avoid either of these propagations you can use msg_wrap.without_context() and MsgWrap::from_no_context(t) respectively.

Implementations

impl<T> MsgWrap<T>

pub fn new(t: T, context: Context) -> Self

Create a T wrapped in a Context. If you just need the current context use t.into().

pub fn inner(self) -> T

Get the inner type and propagate the context to the current span.

pub fn without_context(self) -> T

Get the inner type without propagating the context.

pub fn from_no_context(t: T) -> Self

Create a wrapped T with no Context.

pub fn into_parts(self) -> (T, Context)

Unwrap the wrapped T into a T and Context. If you just need to propagate the context to the current span use msg_wrap.inner()

Trait Implementations

impl<T> Debug for MsgWrap<T> where
    T: Debug, 

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

Formats the value using the given formatter.

impl<T> From<T> for MsgWrap<T>

fn from(t: T) -> Self

Create a wrapped T with the context from the current span.