pub struct InstrumentedThreadWriter { /* private fields */ }Expand description
Writer that can be used to record instrumentation events for a specific thread. It is associated with a specific actor thread, and maintains a mapping from message type names. The actor thread will use the mutable reference to this struct to record events.
Implementations§
Source§impl InstrumentedThreadWriter
impl InstrumentedThreadWriter
Sourcepub fn start_event(&mut self, message_type: &str, dequeue_time_ns: u64)
pub fn start_event(&mut self, message_type: &str, dequeue_time_ns: u64)
Start an event for a specific message type, also recording the time spent in the queue.
pub fn end_event(&mut self, message_type: &str)
Sourcepub fn advance_window_if_needed(&mut self)
pub fn advance_window_if_needed(&mut self)
Advance the current window if needed, based on the current time.
Trait Implementations§
Auto Trait Implementations§
impl Freeze for InstrumentedThreadWriter
impl !RefUnwindSafe for InstrumentedThreadWriter
impl Send for InstrumentedThreadWriter
impl Sync for InstrumentedThreadWriter
impl Unpin for InstrumentedThreadWriter
impl !UnwindSafe for InstrumentedThreadWriter
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
Source§impl<T> FutureExt for T
impl<T> FutureExt for T
Source§fn with_context(self, otel_cx: Context) -> WithContext<Self>
fn with_context(self, otel_cx: Context) -> WithContext<Self>
Source§fn with_current_context(self) -> WithContext<Self>
fn with_current_context(self) -> WithContext<Self>
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<A, B> IntoMultiSender<B> for Awhere
B: MultiSenderFrom<A>,
impl<A, B> IntoMultiSender<B> for Awhere
B: MultiSenderFrom<A>,
fn as_multi_sender(self: &Arc<A>) -> B
fn into_multi_sender(self) -> B
Source§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
Source§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message
T in a tonic::Request