pub struct WebSocketPool { /* private fields */ }Expand description
WebSocket connection pool for managing multiple connections
Implementations§
Source§impl WebSocketPool
impl WebSocketPool
Sourcepub fn new(config: WebSocketPoolConfig) -> Self
pub fn new(config: WebSocketPoolConfig) -> Self
Create a new WebSocket connection pool
Sourcepub fn add_connection(
&mut self,
connection: WebSocketConnection,
) -> Result<(), String>
pub fn add_connection( &mut self, connection: WebSocketConnection, ) -> Result<(), String>
Sourcepub fn get_connection(&self, id: &str) -> Option<&WebSocketConnection>
pub fn get_connection(&self, id: &str) -> Option<&WebSocketConnection>
Get a connection from the pool
Sourcepub fn get_connection_mut(
&mut self,
id: &str,
) -> Option<&mut WebSocketConnection>
pub fn get_connection_mut( &mut self, id: &str, ) -> Option<&mut WebSocketConnection>
Get a mutable connection from the pool
Sourcepub fn remove_connection(&mut self, id: &str) -> Option<WebSocketConnection>
pub fn remove_connection(&mut self, id: &str) -> Option<WebSocketConnection>
Remove a connection from the pool
Sourcepub fn connection_ids(&self) -> Vec<String>
pub fn connection_ids(&self) -> Vec<String>
Get all connection IDs
Sourcepub fn active_connection_count(&self) -> usize
pub fn active_connection_count(&self) -> usize
Get active connection count
Sourcepub fn cleanup_idle_connections(&mut self) -> Vec<String>
pub fn cleanup_idle_connections(&mut self) -> Vec<String>
Clean up idle connections
Trait Implementations§
Auto Trait Implementations§
impl Freeze for WebSocketPool
impl RefUnwindSafe for WebSocketPool
impl Send for WebSocketPool
impl Sync for WebSocketPool
impl Unpin for WebSocketPool
impl UnwindSafe for WebSocketPool
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
Source§impl<C, E> EntryToVal<C> for Ewhere
C: Collection<Entry = E>,
impl<C, E> EntryToVal<C> for Ewhere
C: Collection<Entry = E>,
Source§type Val = <C as Collection>::Val
type Val = <C as Collection>::Val
The type of values stored in the collection. This might be distinct from
Entry in complex collections.
For example, in a HashMap, while Entry might be a ( key, value ) tuple, Val might only be the value part.Source§fn entry_to_val(self) -> <E as EntryToVal<C>>::Val
fn entry_to_val(self) -> <E as EntryToVal<C>>::Val
Converts an entry into a value representation specific to the type of collection. This conversion is crucial
for handling operations on entries, especially when they need to be treated or accessed as individual values,
such as retrieving the value part from a key-value pair in a hash map.
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> IntoResult<T> for T
impl<T> IntoResult<T> for T
type Err = Infallible
fn into_result(self) -> Result<T, <T as IntoResult<T>>::Err>
Source§impl<T> PolicyExt for Twhere
T: ?Sized,
impl<T> PolicyExt for Twhere
T: ?Sized,
Source§impl<C, Val> ValToEntry<C> for Valwhere
C: CollectionValToEntry<Val>,
impl<C, Val> ValToEntry<C> for Valwhere
C: CollectionValToEntry<Val>,
Source§fn val_to_entry(self) -> <C as CollectionValToEntry<Val>>::Entry
fn val_to_entry(self) -> <C as CollectionValToEntry<Val>>::Entry
Invokes the val_to_entry function of the CollectionValToEntry trait to convert the value to an entry.
Source§type Entry = <C as CollectionValToEntry<Val>>::Entry
type Entry = <C as CollectionValToEntry<Val>>::Entry
Represents the type of entry that corresponds to the value within the collection.
Type
Entry is defined by the Collection trait.