Trait opentelemetry_jaeger::JaegerTraceRuntime

pub trait JaegerTraceRuntime: RuntimeChannel<BatchMessage> + Debug {
    type Socket: Debug + Send + Sync;

    // Required methods
    fn create_socket<T: ToSocketAddrs>(
        &self,
        endpoint: T
    ) -> Result<Self::Socket>;
    fn write_to_socket<'life0, 'life1, 'async_trait>(
        &'life0 self,
        socket: &'life1 Self::Socket,
        payload: Vec<u8>
    ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait;
}

Jaeger Trace Runtime is an extension to RuntimeChannel.

Required Associated Types

type Socket: Debug + Send + Sync

A communication socket between Jaeger client and agent.

Required Methods

fn create_socket<T: ToSocketAddrs>(&self, endpoint: T) -> Result<Self::Socket>

Create a new communication socket.

fn write_to_socket<'life0, 'life1, 'async_trait>( &'life0 self, socket: &'life1 Self::Socket, payload: Vec<u8> ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Send payload over the socket.

Implementations on Foreign Types

impl JaegerTraceRuntime for AsyncStd

Available on crate feature rt-async-std only.

type Socket = UdpSocket

fn create_socket<T: ToSocketAddrs>(&self, endpoint: T) -> Result<Self::Socket>

fn write_to_socket<'life0, 'life1, 'async_trait>( &'life0 self, socket: &'life1 Self::Socket, payload: Vec<u8> ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

impl JaegerTraceRuntime for Tokio

Available on crate feature rt-tokio only.

type Socket = UdpSocket

fn create_socket<T: ToSocketAddrs>(&self, endpoint: T) -> Result<Self::Socket>

fn write_to_socket<'life0, 'life1, 'async_trait>( &'life0 self, socket: &'life1 Self::Socket, payload: Vec<u8> ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

impl JaegerTraceRuntime for TokioCurrentThread

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

type Socket = UdpSocket

fn create_socket<T: ToSocketAddrs>(&self, endpoint: T) -> Result<Self::Socket>

fn write_to_socket<'life0, 'life1, 'async_trait>( &'life0 self, socket: &'life1 Self::Socket, payload: Vec<u8> ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Implementors