Struct WsEndpointManager

pub struct WsEndpointManager {
    pub active_url: Arc<RwLock<String>>,
    pub fallback_urls: Arc<RwLock<Vec<String>>>,
    /* private fields */
}

Manages WebSocket RPC endpoint rotation and failover

This struct provides thread-safe management of WebSocket connections to blockchain nodes, handling automatic failover between multiple endpoints based on their weights and health.

Fields

• active_url - The currently active WebSocket endpoint URL
• fallback_urls - List of fallback URLs to use when the active URL fails
• rotation_lock - Mutex to ensure thread-safe URL rotation
• config - Configuration settings for WebSocket connections

Fields

active_url: Arc<RwLock<String>>

The currently active WebSocket endpoint URL

fallback_urls: Arc<RwLock<Vec<String>>>

List of fallback URLs to use when the active URL fails

Implementations

impl EndpointManager

pub fn new( config: &WsConfig, active_url: &str, fallback_urls: Vec<String>, ) -> Self

Creates a new WebSocket endpoint manager

Initializes the endpoint manager with a primary URL and a list of fallback URLs. The URLs should be pre-sorted by weight, with the highest weight URL as the active one.

Arguments

• config - WebSocket configuration settings
• active_url - The initial active WebSocket URL
• fallback_urls - List of fallback URLs, pre-sorted by weight

Returns

A new EndpointManager instance

pub async fn rotate_url<T: RotatingTransport>( &self, transport: &T, ) -> Result<(), Error>

Rotates to the next available WebSocket URL

Attempts to connect to a different URL from the fallback list. If successful, updates the active URL and moves the old active URL to the fallback list.

Arguments

• transport - The transport client implementing the RotatingTransport trait

Returns

• Ok(()) if rotation was successful
• Err if no fallback URLs are available or connection fails

pub async fn get_active_url(&self) -> Result<String, Error>

Retrieves the currently active WebSocket URL

Returns

• Ok(String) containing the active URL
• Err if no active URL is set

pub async fn should_rotate(&self) -> bool

Checks if URL rotation should be attempted

Determines if there are any fallback URLs available for rotation.

Returns

true if rotation should be attempted, false otherwise

Trait Implementations

impl Clone for EndpointManager

fn clone(&self) -> EndpointManager

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for EndpointManager

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

Formats the value using the given formatter.