Struct QuicTpuConnection

pub struct QuicTpuConnection {
    pub client: Arc<QuicClient>,
    pub connection_stats: Arc<ConnectionCacheStats>,
}

Fields

client: Arc<QuicClient>

connection_stats: Arc<ConnectionCacheStats>

Implementations

impl QuicClientConnection

pub fn base_stats(&self) -> Arc<ClientStats>

pub fn connection_stats(&self) -> Arc<ConnectionCacheStats>

pub fn new( endpoint: Arc<QuicLazyInitializedEndpoint>, addr: SocketAddr, connection_stats: Arc<ConnectionCacheStats>, ) -> QuicClientConnection

pub fn new_with_client( client: Arc<QuicClient>, connection_stats: Arc<ConnectionCacheStats>, ) -> QuicClientConnection

Trait Implementations

impl ClientConnection for QuicClientConnection

fn server_addr(&self) -> &SocketAddr

fn send_data_batch<'life0, 'life1, 'async_trait>( &'life0 self, buffers: &'life1 [Vec<u8>], ) -> Pin<Box<dyn Future<Output = Result<(), TransportError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, QuicClientConnection: 'async_trait,

fn send_data<'life0, 'life1, 'async_trait>( &'life0 self, data: &'life1 [u8], ) -> Pin<Box<dyn Future<Output = Result<(), TransportError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, QuicClientConnection: 'async_trait,