Struct EndpointManager

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

Manages the rotation of blockchain RPC endpoints

Provides methods for rotating between multiple URLs and sending requests to the active endpoint with automatic fallback to other URLs on failure.

Fields

• active_url - The current active URL
• fallback_urls - A list of fallback URLs to rotate to
• client - The client to use for the endpoint manager
• rotation_lock - A lock for managing the rotation process

Fields

active_url: Arc<RwLock<String>>

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

Implementations

impl EndpointManager

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

Creates a new rotating URL client

Arguments

• client - The client to use for the endpoint manager
• active_url - The initial active URL
• fallback_urls - A list of fallback URLs to rotate to

Returns

pub fn update_client(&mut self, client: ClientWithMiddleware)

Updates the client with a new client

Useful for updating the client with a new retry policy or strategy

Arguments

• client - The new client to use for the endpoint manager

pub fn set_retry_policy<R: RetryableStrategy + Send + Sync + 'static>( &mut self, retry_policy: ExponentialBackoff, retry_strategy: R, )

Updates the retry policy for the client

Constructs a new client with the given retry policy and strategy and updates the endpoint manager with the new client

Arguments

• retry_policy - The new retry policy to use for the client
• retry_strategy - The new retry strategy to use for the client

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

Rotates to the next available URL

Arguments

• transport - The transport client implementing the RotatingTransport trait

Returns

• Result<(), anyhow::Error> - The result of the rotation operation

pub async fn send_raw_request<T: RotatingTransport, P: Into<Value> + Send + Clone + Serialize>( &self, transport: &T, method: &str, params: Option<P>, ) -> Result<Value, Error>

Sends a raw request to the blockchain RPC endpoint with automatic URL rotation on failure

Arguments

• transport - The transport client implementing the RotatingTransport trait
• method - The RPC method name to call
• params - The parameters for the RPC method call as a JSON Value

Returns

• Result<Value, anyhow::Error> - The JSON response from the RPC endpoint or an error

Behavior

• Automatically rotates to fallback URLs if the request fails with specific status codes (e.g., 429)
• Retries the request with the new URL after rotation
• Returns the first successful response or an error if all attempts fail

Trait Implementations

impl Clone for EndpointManager

fn clone(&self) -> EndpointManager

Returns a copy 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.