Struct opentelemetry::sdk::runtime::TokioCurrentThread
source · pub struct TokioCurrentThread;
Available on crate feature
rt-tokio-current-thread
only.Expand description
Runtime implementation, which works with Tokio’s current thread runtime.
Trait Implementations§
source§impl Clone for TokioCurrentThread
impl Clone for TokioCurrentThread
source§fn clone(&self) -> TokioCurrentThread
fn clone(&self) -> TokioCurrentThread
Returns a copy of the value. Read more
1.0.0 · source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source
. Read moresource§impl Debug for TokioCurrentThread
impl Debug for TokioCurrentThread
source§impl Runtime for TokioCurrentThread
impl Runtime for TokioCurrentThread
§type Interval = IntervalStream
type Interval = IntervalStream
A future stream, which returns items in a previously specified interval. The item type is
not important.
§type Delay = Pin<Box<Sleep, Global>>
type Delay = Pin<Box<Sleep, Global>>
A future, which resolves after a previously specified amount of time. The output type is
not important.
source§fn interval(
&self,
duration: Duration
) -> <TokioCurrentThread as Runtime>::Interval
fn interval( &self, duration: Duration ) -> <TokioCurrentThread as Runtime>::Interval
Create a [Stream][futures_util::stream::Stream], which returns a new item every
Duration.
source§impl TraceRuntime for TokioCurrentThread
impl TraceRuntime for TokioCurrentThread
§type Receiver = ReceiverStream<BatchMessage>
type Receiver = ReceiverStream<BatchMessage>
A future stream to receive the batch messages from channels.
§type Sender = Sender<BatchMessage>
type Sender = Sender<BatchMessage>
A batch messages sender that could be sent across thread safely.
source§fn batch_message_channel(
&self,
capacity: usize
) -> (<TokioCurrentThread as TraceRuntime>::Sender, <TokioCurrentThread as TraceRuntime>::Receiver)
fn batch_message_channel( &self, capacity: usize ) -> (<TokioCurrentThread as TraceRuntime>::Sender, <TokioCurrentThread as TraceRuntime>::Receiver)
Return the sender and receiver used to send batch message between tasks.