Enum ConnectionCache

pub enum ConnectionCache {
    Quic(Arc<ConnectionCache<QuicPool, QuicConnectionManager, QuicConfig>>),
    Udp(Arc<ConnectionCache<UdpPool, UdpConnectionManager, UdpConfig>>),
}

A thin wrapper over connection-cache/ConnectionCache to ease construction of the ConnectionCache for code dealing both with udp and quic. For the scenario only using udp or quic, use connection-cache/ConnectionCache directly.

Variants

Quic(Arc<ConnectionCache<QuicPool, QuicConnectionManager, QuicConfig>>)

Udp(Arc<ConnectionCache<UdpPool, UdpConnectionManager, UdpConfig>>)

Implementations

impl ConnectionCache

pub fn new(name: &'static str) -> Self

pub fn new_quic(name: &'static str, connection_pool_size: usize) -> Self

Create a quic connection_cache

pub fn new_with_client_options( name: &'static str, connection_pool_size: usize, client_endpoint: Option<Endpoint>, cert_info: Option<(&Keypair, IpAddr)>, stake_info: Option<(&Arc<RwLock<StakedNodes>>, &Pubkey)>, ) -> Self

Create a quic connection_cache with more client options

pub fn protocol(&self) -> Protocol

pub fn with_udp(name: &'static str, connection_pool_size: usize) -> Self

pub fn use_quic(&self) -> bool

pub fn get_connection(&self, addr: &SocketAddr) -> BlockingClientConnection

pub fn get_nonblocking_connection( &self, addr: &SocketAddr, ) -> NonblockingClientConnection

Trait Implementations

impl NotifyKeyUpdate for ConnectionCache

fn update_key(&self, key: &Keypair) -> Result<(), Box<dyn Error>>