Struct StellarTransportClient

pub struct StellarTransportClient { /* private fields */ }

A client for interacting with Stellar-compatible blockchain nodes

This implementation wraps the HttpTransportClient to provide consistent behavior with other transport implementations while offering Stellar-specific functionality. It handles connection management, request retries, and endpoint rotation for Stellar-based networks.

Implementations

impl StellarTransportClient

pub async fn new(network: &Network) -> Result<Self, Error>

Creates a new Stellar transport client by initializing an HTTP transport client

Arguments

• network - Network configuration containing RPC URLs and other network details

Returns

• Result<Self, anyhow::Error> - A new client instance or connection error

Trait Implementations

impl BlockchainTransport for StellarTransportClient

fn get_current_url<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = String> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Gets the current active RPC URL

Returns

• String - The currently active RPC endpoint URL

fn send_raw_request<'life0, 'life1, 'async_trait, P>( &'life0 self, method: &'life1 str, params: Option<P>, ) -> Pin<Box<dyn Future<Output = Result<Value, Error>> + Send + 'async_trait>>

where P: Into<Value> + Send + Clone + Serialize + 'async_trait, Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Sends a raw JSON-RPC request to the Stellar node

Arguments

• method - The JSON-RPC method to call
• params - Optional parameters to pass with the request

Returns

• Result<Value, anyhow::Error> - The JSON response or error

fn set_retry_policy( &mut self, retry_policy: ExponentialBackoff, retry_strategy: Option<TransientErrorRetryStrategy>, ) -> Result<(), Error>

Sets a new retry policy for the transport

Arguments

• retry_policy - The new retry policy to use
• retry_strategy - The new retry strategy to use

Returns

• Result<(), anyhow::Error> - Success or error status

fn update_endpoint_manager_client( &mut self, client: ClientWithMiddleware, ) -> Result<(), Error>

Update endpoint manager with a new client

Arguments

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

fn customize_request<'life0, 'life1, 'async_trait, P>( &'life0 self, method: &'life1 str, params: Option<P>, ) -> Pin<Box<dyn Future<Output = Value> + Send + 'async_trait>>

where P: Into<Value> + Send + Clone + Serialize + 'async_trait, Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Customizes the request for specific blockchain requirements

impl Clone for StellarTransportClient

fn clone(&self) -> StellarTransportClient

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for StellarTransportClient

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

Formats the value using the given formatter.

impl RotatingTransport for StellarTransportClient

fn try_connect<'life0, 'life1, 'async_trait>( &'life0 self, url: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Tests connection to a specific URL

Arguments

• url - The URL to test connection with

Returns

• Result<(), anyhow::Error> - Success or error status

fn update_client<'life0, 'life1, 'async_trait>( &'life0 self, url: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Updates the client to use a new URL

Arguments

• url - The new URL to use for subsequent requests

Returns

• Result<(), anyhow::Error> - Success or error status