Struct safecoin_client::nonblocking::quic_client::QuicTpuConnection

pub struct QuicTpuConnection { /* private fields */ }

Implementations

impl QuicTpuConnection

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> ) -> Self

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

Trait Implementations

impl From<QuicTpuConnection> for NonblockingConnection

fn from(v: QuicTpuConnection) -> NonblockingConnection

Converts to this type from the input type.

impl TpuConnection for QuicTpuConnection

fn tpu_addr(&self) -> &SocketAddr

fn send_wire_transaction_batch<'life0, 'life1, 'async_trait, T>( &'life0 self, buffers: &'life1 [T] ) -> Pin<Box<dyn Future<Output = TransportResult<()>> + Send + 'async_trait>>where T: AsRef<[u8]> + Send + Sync + 'async_trait, Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn send_wire_transaction<'life0, 'async_trait, T>( &'life0 self, wire_transaction: T ) -> Pin<Box<dyn Future<Output = TransportResult<()>> + Send + 'async_trait>>where T: AsRef<[u8]> + Send + Sync + 'async_trait, Self: 'async_trait, 'life0: 'async_trait,

fn serialize_and_send_transaction<'life0, 'life1, 'async_trait>( &'life0 self, transaction: &'life1 VersionedTransaction ) -> Pin<Box<dyn Future<Output = TransportResult<()>> + Send + 'async_trait>>where Self: Sync + 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

impl TryInto<QuicTpuConnection> for NonblockingConnection

type Error = &'static str

The type returned in the event of a conversion error.

fn try_into( self ) -> Result<QuicTpuConnection, <Self as TryInto<QuicTpuConnection>>::Error>

Performs the conversion.