Struct fluvio_socket::SocketPool

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

pooling of sockets

Implementations

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

pub fn new() -> Self

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

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

get valid client. return only client which is not stale

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

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

make connection where id can be used as address

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

pub async fn make_connection_with_addr(
    &self,
    id: T,
    addr: &str
) -> Result<(), FlvSocketError>

make connection with addres as separate parameter

pub async fn get_or_make<'a>(
    &'a self,
    id: T,
    addr: &'a str
) -> Result<Option<WriteGuard<'a, T, FlvSocket>>, FlvSocketError>

get existing socket connection or make new one

Trait Implementations

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

pub fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

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

pub fn default() -> Self

Returns the "default value" for a type.