Struct RelayPool 

pub struct RelayPool { /* private fields */ }

The relay pool — manages multiple WebSocket connections with bidirectional messaging.

Inbound events flow through an MPSC ring buffer with deduplication. Outbound messages are broadcast to all relay threads via a lock-free broadcast ring.

Implementations

impl RelayPool

pub fn new( ring_capacity: usize, cache_size: usize, broadcast_capacity: usize, max_relays: usize, ) -> Self

Create a new relay pool with bidirectional messaging.

Arguments

• ring_capacity - MPSC ring buffer size for inbound event throughput
• cache_size - Deduplication cache size (e.g. 10,000)
• broadcast_capacity - Broadcast ring buffer size for outbound messages
• max_relays - Maximum number of relay connections (broadcast consumer slots)

pub fn add_relay(&mut self, relay_url: String)

Add a relay connection to the pool.

Spawns a new thread that connects to the relay, reads inbound events, and sends outbound messages from the broadcast ring.

Automatically cleans up dead connections first to free broadcast slots.

pub fn remove_relay(&mut self, relay_url: &str) -> bool

Remove a relay from the pool by URL.

Signals the relay thread to shut down and blocks until it exits (~1-2ms). The broadcast consumer slot is freed immediately.

Returns true if the relay was found and removed.

pub fn cleanup(&mut self)

Remove dead connections from the pool.

Joins finished threads and frees their broadcast consumer slots. Called automatically by [add_relay], but can be called explicitly to update [connection_count].

pub fn sender(&self) -> PoolSender

Get a cloneable sender handle for broadcasting to all relays.

Multiple threads can hold a PoolSender and send concurrently.

pub fn recv(&mut self) -> PoolMessage

Receive the next event from any relay (blocking)

pub fn try_recv(&mut self) -> Option<PoolMessage>

Receive the next event from any relay (non-blocking)

pub fn connection_count(&self) -> usize

Get the total number of connections (including dead ones not yet cleaned up).

pub fn active_connection_count(&self) -> usize

Get the number of connections whose threads are still running.

pub fn relay_urls(&self) -> Vec<&str>

Get the relay URLs of all connections in the pool.

pub fn active_relay_urls(&self) -> Vec<&str>

Get the relay URLs of only active (thread still running) connections.

Trait Implementations

impl Drop for RelayPool

fn drop(&mut self)

Executes the destructor for this type.