Trait TraceRuntime

pub trait TraceRuntime: Runtime {
    type Receiver: Stream<Item = BatchMessage> + Send;
    type Sender: TrySend + Debug;

    // Required method
    fn batch_message_channel(
        &self,
        capacity: usize,
    ) -> (Self::Sender, Self::Receiver);
}

Available on crate feature trace only.

Trace runtime is an extension to Runtime. Currently it provides a channel that used by BatchSpanProcessor.

Required Associated Types

type Receiver: Stream<Item = BatchMessage> + Send

A future stream to receive the batch messages from channels.

type Sender: TrySend + Debug

A batch messages sender that could be sent across thread safely.

Required Methods

fn batch_message_channel( &self, capacity: usize, ) -> (Self::Sender, Self::Receiver)

Return the sender and receiver used to send batch message between tasks.

Dyn Compatibility

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety", so this trait is not object safe.

Implementors

impl TraceRuntime for AsyncStd

Available on crate feature rt-async-std only.

type Receiver = Receiver<BatchMessage>

type Sender = Sender<BatchMessage>

impl TraceRuntime for Tokio

Available on crate feature rt-tokio only.

type Receiver = ReceiverStream<BatchMessage>

type Sender = Sender<BatchMessage>

impl TraceRuntime for TokioCurrentThread

Available on crate feature rt-tokio-current-thread only.

type Receiver = ReceiverStream<BatchMessage>

type Sender = Sender<BatchMessage>