Struct safecoin_client::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 fn send_transaction(&self, transaction: &Transaction) -> bool

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

pub 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 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 fn try_send_transaction_batch( &self, transactions: &[Transaction] ) -> TransportResult<()>

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

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

Create a new client that disconnects when dropped

pub 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 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

Trait Implementations

impl Drop for TpuClient

fn drop(&mut self)

Executes the destructor for this type.