Struct InstrumentedThreadWriterSharedPart 

pub struct InstrumentedThreadWriterSharedPart { /* private fields */ }

Shared part of the instrumentation that is shared between all threads of an actor. Most importantly, it contains the reference to the queue, which is shared between all threads. It also contains the clock and reference instant to compute timestamps.

Implementations

impl InstrumentedThreadWriterSharedPart

pub fn new(actor_name: String, queue: Arc<InstrumentedQueue>) -> Arc<Self>

pub fn new_for_test( actor_name: String, clock: Clock, reference_instant: Instant, queue: Arc<InstrumentedQueue>, ) -> Arc<Self>

pub fn current_time(&self) -> u64

pub fn queue(&self) -> &InstrumentedQueue

pub fn new_writer_with_global_registration( self: &Arc<Self>, thread_index: Option<usize>, ) -> InstrumentedThreadWriter

pub fn new_writer_for_test( self: &Arc<Self>, target: Arc<InstrumentedThread>, ) -> InstrumentedThreadWriter

pub fn with_thread_local_writer( self: &Arc<Self>, f: impl FnOnce(&mut InstrumentedThreadWriter), )