Struct safecoin_client::nonblocking::tpu_client::TpuClient

pub struct TpuClient { /* private fields */ }

Client which sends transactions directly to the current leader’s TPU port over UDP. The client uses RPC to determine the current leader and fetch node contact info

Implementations

impl TpuClient

pub async fn send_transaction(&self, transaction: &Transaction) -> bool

Serialize and send transaction to the current and upcoming leader TPUs according to fanout size

pub async fn send_wire_transaction(&self, wire_transaction: Vec<u8>) -> bool

Send a wire transaction to the current and upcoming leader TPUs according to fanout size

pub async fn try_send_transaction( &self, transaction: &Transaction ) -> TransportResult<()>

Serialize and send transaction to the current and upcoming leader TPUs according to fanout size Returns the last error if all sends fail

pub async fn try_send_wire_transaction_batch( &self, wire_transactions: Vec<Vec<u8>> ) -> TransportResult<()>

Send a batch of wire transactions to the current and upcoming leader TPUs according to fanout size Returns the last error if all sends fail

pub async fn new( rpc_client: Arc<RpcClient>, websocket_url: &str, config: TpuClientConfig ) -> Result<Self, TpuSenderError>

Create a new client that disconnects when dropped

pub async fn new_with_connection_cache( rpc_client: Arc<RpcClient>, websocket_url: &str, config: TpuClientConfig, connection_cache: Arc<ConnectionCache> ) -> Result<Self, TpuSenderError>

Create a new client that disconnects when dropped

pub async fn send_and_confirm_messages_with_spinner<T: Signers>( &self, messages: &[Message], signers: &T ) -> Result<Vec<Option<TransactionError>>, TpuSenderError>

pub fn rpc_client(&self) -> &RpcClient

pub async fn shutdown(&mut self)

Trait Implementations

impl Drop for TpuClient

fn drop(&mut self)

Executes the destructor for this type.