Struct opentelemetry::runtime::Tokio

pub struct Tokio;

Runtime implementation, which works with Tokio’s multi thread runtime.

Trait Implementations

impl Clone for Tokio

fn clone(&self) -> Tokio

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for Tokio

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

Formats the value using the given formatter.

impl Runtime for Tokio

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>>

A future, which resolves after a previously specified amount of time. The output type is not important.

fn interval(&self, duration: Duration) -> <Tokio as Runtime>::Interval

Create a Stream, which returns a new item every Duration.

fn spawn(&self, future: Pin<Box<dyn Future<Output = ()> + Send>>)

Spawn a new task or thread, which executes the given future.

fn delay(&self, duration: Duration) -> <Tokio as Runtime>::Delay

Return a new future, which resolves after the specified Duration.

impl<T> RuntimeChannel<T> for Tokiowhere T: Debug + Send,

type Receiver = ReceiverStream<T>

A future stream to receive batch messages from channels.

type Sender = Sender<T>

A batch messages sender that can be sent across threads safely.

fn batch_message_channel( &self, capacity: usize ) -> (<Tokio as RuntimeChannel<T>>::Sender, <Tokio as RuntimeChannel<T>>::Receiver)

Return the sender and receiver used to send batch messages.