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
sourceimpl Clone for TokioCurrentThread
impl Clone for TokioCurrentThread
sourcefn clone(&self) -> TokioCurrentThread
fn clone(&self) -> TokioCurrentThread
Returns a copy of the value. Read more
1.0.0 · sourcefn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from source
. Read more
sourceimpl Debug for TokioCurrentThread
impl Debug for TokioCurrentThread
sourceimpl 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. Read more
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. Read more
sourceimpl 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.
sourcefn 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.
Auto Trait Implementations
impl RefUnwindSafe for TokioCurrentThread
impl Send for TokioCurrentThread
impl Sync for TokioCurrentThread
impl Unpin for TokioCurrentThread
impl UnwindSafe for TokioCurrentThread
Blanket Implementations
sourceimpl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
const: unstable · sourcefn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more