Trait opentelemetry_jaeger::JaegerTraceRuntime

pub trait JaegerTraceRuntime: TraceRuntime + Debug {
    type Socket: Debug + Send + Sync;

    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
        'life0: 'async_trait,
        'life1: 'async_trait,
        Self: 'async_trait;
}

Jaeger Trace Runtime is an extension to TraceRuntime.

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
    'life0: 'async_trait,
    'life1: 'async_trait,
    Self: 'async_trait,

Send payload over the socket.

Implementations on Foreign Types

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
    'life0: 'async_trait,
    'life1: 'async_trait,
    Self: '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
    'life0: 'async_trait,
    'life1: 'async_trait,
    Self: 'async_trait,

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
    'life0: 'async_trait,
    'life1: 'async_trait,
    Self: 'async_trait,

Implementors