Struct HyperProcMsg

pub struct HyperProcMsg<M>
where
    M: 'static + Send + Sync + Sized + Clone + Debug + Tvf + Default,
{ /* private fields */ }

Hyper processor

Implementations

impl<M> HyperProcMsg<M>

where M: 'static + Send + Sync + Sized + Clone + Debug + Tvf + Default,

pub fn new( service: String, data: M, response_queue: Sender<InternalMsg<M>>, ) -> HyperProcMsg<M>

Create a new Hyper processor message

pub fn set_id(&mut self, id: u64)

Set the ID of the Hyper processor

Trait Implementations

impl<M> Debug for HyperProcMsg<M>

where M: 'static + Send + Sync + Sized + Clone + Debug + Tvf + Default + Debug,

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

Formats the value using the given formatter.

impl<M> Msg<M> for HyperProcMsg<M>

where M: 'static + Send + Sync + Sized + Clone + Debug + Tvf + Default,

fn get_id(&self) -> u64

Getter of the message id

fn get_service(&self) -> &String

Getter of the service name

fn get_span(&self) -> &Span

Getter of the span of the message (use for metrics)

fn get_span_mut(&mut self) -> &mut Span

Getter of the mutable span of the message (use to add informations for metrics)

fn enter_span(&self) -> Entered<'_>

Enter the span and push metadata in it

fn get_data(&self) -> &M

Getter of the message content

fn get_data_mut(&mut self) -> &mut M

Getter of the mutable message content

fn elapsed(&self) -> Duration

Return the elapsed time corresponding to the processing time (duration since the request creation)