Struct TpuClient

pub struct TpuClient<P, M, C> { /* 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<P, M, C> TpuClient<P, M, C>

where P: ConnectionPool<NewConnectionConfig = C>, M: ConnectionManager<ConnectionPool = P, NewConnectionConfig = C>, C: NewConnectionConfig,

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( &self, wire_transaction: Vec<u8>, ) -> TransportResult<()>

Send a wire 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( name: &'static str, rpc_client: Arc<RpcClient>, websocket_url: &str, config: TpuClientConfig, connection_manager: M, ) -> Result<Self>

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<P, M, C>>, ) -> Result<Self>

Create a new client that disconnects when dropped

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

pub fn rpc_client(&self) -> &RpcClient

pub async fn shutdown(&mut self)

pub fn get_connection_cache(&self) -> &Arc<ConnectionCache<P, M, C>>

where P: ConnectionPool<NewConnectionConfig = C>, M: ConnectionManager<ConnectionPool = P, NewConnectionConfig = C>, C: NewConnectionConfig,

pub fn get_leader_tpu_service(&self) -> &LeaderTpuService

pub fn get_fanout_slots(&self) -> u64

Trait Implementations

impl<P, M, C> Drop for TpuClient<P, M, C>

fn drop(&mut self)

Executes the destructor for this type.