Struct kf_socket::SocketPool

pub struct SocketPool<T> where
    T: Eq + Hash,  { /* fields omitted */ }

pooling of sockets

Methods

impl<T> SocketPool<T> where
    T: Eq + PartialEq + Hash + Debug + Clone,
    KfSocket: Sync, 

pub fn new() -> Self

pub fn insert_socket(&self, id: T, socket: KfSocket)

pub fn get_socket(&self, id: &T) -> Option<WriteGuard<T, KfSocket>>

get valid client. return only client which is not stale

impl<T> SocketPool<T> where
    T: Eq + PartialEq + Hash + Debug + Clone + ToSocketAddrs,
    KfSocket: Sync, 

pub async fn make_connection<'_>(&'_ self, id: T) -> Result<(), KfSocketError>

make connection where id can be used as address

impl<T> SocketPool<T> where
    T: Eq + PartialEq + Hash + Debug + Clone,
    KfSocket: Sync, 

pub async fn make_connection_with_addr<'a, A>(
    &'a self,
    id: T,
    addr: &'a A
) -> Result<(), KfSocketError> where
    A: ToSocketAddrs + Debug, 

make connection with addres as separate parameter

pub async fn get_or_make<'a, A>(
    &'a self,
    id: T,
    addr: &'a A
) -> Result<Option<WriteGuard<'a, T, KfSocket>>, KfSocketError> where
    A: ToSocketAddrs + Debug, 

get existing socket connection or make new one

Trait Implementations

impl<T: Debug> Debug for SocketPool<T> where
    T: Eq + Hash, 

fn fmt(&self, f: &mut Formatter) -> Result

Formats the value using the given formatter.