Struct solana_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.