Trait opentelemetry_jaeger::JaegerTraceRuntime

pub trait JaegerTraceRuntime: TraceRuntime + Debug {
    type Socket: Debug + Send + Sync;
    fn create_socket<T: ToSocketAddrs>(
        &self, 
        host_port: 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
        'life0: 'async_trait,
        'life1: 'async_trait,
        Self: 'async_trait;
}

Jaeger Trace Runtime is an extension to TraceRuntime. Currently it provides a UDP socket used by AgentAsyncClientUdp.

Associated Types

type Socket: Debug + Send + Sync

A communication socket between Jaeger client and agent.

Required methods

fn create_socket<T: ToSocketAddrs>(&self, host_port: 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
    'life0: 'async_trait,
    'life1: 'async_trait,
    Self: 'async_trait, 

Send payload over the socket.

Implementations on Foreign Types

impl JaegerTraceRuntime for Tokio

This is supported on crate feature rt-tokio only.

type Socket = UdpSocket

fn create_socket<T: ToSocketAddrs>(&self, host_port: 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
    'life0: 'async_trait,
    'life1: 'async_trait,
    Self: 'async_trait, 

impl JaegerTraceRuntime for TokioCurrentThread

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

type Socket = UdpSocket

fn create_socket<T: ToSocketAddrs>(&self, host_port: 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
    'life0: 'async_trait,
    'life1: 'async_trait,
    Self: 'async_trait, 

impl JaegerTraceRuntime for AsyncStd

type Socket = UdpSocket

fn create_socket<T: ToSocketAddrs>(&self, host_port: 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
    'life0: 'async_trait,
    'life1: 'async_trait,
    Self: 'async_trait, 

Implementors