Trait opentelemetry::sdk::trace::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.

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>