Trait opentelemetry::sdk::trace::TraceRuntime

pub trait TraceRuntime: Runtime {
    type Receiver: Stream<Item = BatchMessage> + Send;
    type Sender: TrySend + Debug;
    fn batch_message_channel(
        &self, 
        capacity: usize
    ) -> (Self::Sender, Self::Receiver);
}

This is supported on crate feature trace only.

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

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.

Implementors

impl TraceRuntime for AsyncStd

This is supported on crate feature rt-async-std only.

type Receiver = Receiver<BatchMessage>

type Sender = Sender<BatchMessage>

impl TraceRuntime for Tokio

This is supported on crate feature rt-tokio only.

type Receiver = ReceiverStream<BatchMessage>

type Sender = Sender<BatchMessage>

impl TraceRuntime for TokioCurrentThread

This is supported on crate feature rt-tokio-current-thread only.

type Receiver = ReceiverStream<BatchMessage>

type Sender = Sender<BatchMessage>