Struct HttpRpcClient 

pub struct HttpRpcClient { /* private fields */ }

HTTP JSON-RPC client with built-in reliability features.

Implementations

impl HttpRpcClient

pub fn new(url: impl Into<String>, config: HttpClientConfig) -> Self

Create a new client for the given JSON-RPC endpoint URL.

pub fn with_metrics( url: impl Into<String>, config: HttpClientConfig, metrics: Arc<ProviderMetrics>, ) -> Self

Create a new client with metrics recording enabled.

pub fn default_for(url: impl Into<String>) -> Self

Create with default configuration.

Trait Implementations

impl RpcTransport for HttpRpcClient

fn send_batch<'life0, 'async_trait>( &'life0 self, reqs: Vec<JsonRpcRequest>, ) -> Pin<Box<dyn Future<Output = Result<Vec<JsonRpcResponse>, TransportError>> + Send + 'async_trait>>

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

True HTTP batch: send all requests as a JSON array in one HTTP call.

fn send<'life0, 'async_trait>( &'life0 self, req: JsonRpcRequest, ) -> Pin<Box<dyn Future<Output = Result<JsonRpcResponse, TransportError>> + Send + 'async_trait>>

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

Send a single JSON-RPC request and return the response.

fn health(&self) -> HealthStatus

Return the current health status of this transport.

fn url(&self) -> &str

Return the transport’s identifier (URL or name).

fn call<'life0, 'life1, 'async_trait, T>( &'life0 self, id: u64, method: &'life1 str, params: Vec<Value>, ) -> Pin<Box<dyn Future<Output = Result<T, TransportError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, Self: Sized + 'async_trait, T: 'async_trait + DeserializeOwned,

Convenience: call a method and deserialize the result.