Trait solana_client::tpu_connection::TpuConnection

pub trait TpuConnection {
    fn new(client_socket: UdpSocket, tpu_addr: SocketAddr) -> Self;
    fn tpu_addr(&self) -> &SocketAddr;
    fn send_wire_transaction<T>(
        &self, 
        wire_transaction: T, 
        stats: &ClientStats
    ) -> TransportResult<()>
    where
        T: AsRef<[u8]>;
    fn send_wire_transaction_async(
        &self, 
        wire_transaction: Vec<u8>, 
        stats: Arc<ClientStats>
    ) -> TransportResult<()>;
    fn send_wire_transaction_batch<T>(
        &self, 
        buffers: &[T], 
        stats: &ClientStats
    ) -> TransportResult<()>
    where
        T: AsRef<[u8]>;
    fn send_wire_transaction_batch_async(
        &self, 
        buffers: Vec<Vec<u8>>, 
        stats: Arc<ClientStats>
    ) -> TransportResult<()>;

    fn serialize_and_send_transaction(
        &self, 
        transaction: &VersionedTransaction, 
        stats: &ClientStats
    ) -> TransportResult<()> { ... }
    fn par_serialize_and_send_transaction_batch(
        &self, 
        transactions: &[VersionedTransaction], 
        stats: &ClientStats
    ) -> TransportResult<()> { ... }
}

Required Methods

fn new(client_socket: UdpSocket, tpu_addr: SocketAddr) -> Self

fn tpu_addr(&self) -> &SocketAddr

fn send_wire_transaction<T>(
    &self,
    wire_transaction: T,
    stats: &ClientStats
) -> TransportResult<()> where
    T: AsRef<[u8]>, 

fn send_wire_transaction_async(
    &self,
    wire_transaction: Vec<u8>,
    stats: Arc<ClientStats>
) -> TransportResult<()>

fn send_wire_transaction_batch<T>(
    &self,
    buffers: &[T],
    stats: &ClientStats
) -> TransportResult<()> where
    T: AsRef<[u8]>, 

fn send_wire_transaction_batch_async(
    &self,
    buffers: Vec<Vec<u8>>,
    stats: Arc<ClientStats>
) -> TransportResult<()>

Provided Methods

fn serialize_and_send_transaction(
    &self,
    transaction: &VersionedTransaction,
    stats: &ClientStats
) -> TransportResult<()>

fn par_serialize_and_send_transaction_batch(
    &self,
    transactions: &[VersionedTransaction],
    stats: &ClientStats
) -> TransportResult<()>

Implementors

impl TpuConnection for QuicTpuConnection

impl TpuConnection for UdpTpuConnection