Struct solana_udp_client::UdpPool
source · pub struct UdpPool { /* private fields */ }
Trait Implementations§
source§impl ConnectionPool for UdpPool
impl ConnectionPool for UdpPool
type BaseClientConnection = Udp
type NewConnectionConfig = UdpConfig
source§fn add_connection(
&mut self,
config: &Self::NewConnectionConfig,
addr: &SocketAddr
)
fn add_connection( &mut self, config: &Self::NewConnectionConfig, addr: &SocketAddr )
Add a connection to the pool
source§fn num_connections(&self) -> usize
fn num_connections(&self) -> usize
Get the number of current connections in the pool
source§fn get(
&self,
index: usize
) -> Result<Arc<Self::BaseClientConnection>, ConnectionPoolError>
fn get( &self, index: usize ) -> Result<Arc<Self::BaseClientConnection>, ConnectionPoolError>
Get a connection based on its index in the pool, without checking if the
fn create_pool_entry( &self, config: &Self::NewConnectionConfig, _addr: &SocketAddr ) -> Arc<Self::BaseClientConnection>
source§fn borrow_connection(&self) -> Arc<Self::BaseClientConnection>
fn borrow_connection(&self) -> Arc<Self::BaseClientConnection>
Get a connection from the pool. It must have at least one connection in the pool.
This randomly picks a connection in the pool.
source§fn need_new_connection(&self, required_pool_size: usize) -> bool
fn need_new_connection(&self, required_pool_size: usize) -> bool
Check if we need to create a new connection. If the count of the connections
is smaller than the pool size.
Auto Trait Implementations§
impl RefUnwindSafe for UdpPool
impl Send for UdpPool
impl Sync for UdpPool
impl Unpin for UdpPool
impl UnwindSafe for UdpPool
Blanket Implementations§
source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere T: ?Sized,
source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more