Struct HttpClient 

pub struct HttpClient { /* private fields */ }

HTTP client with retry and rate limiting support

Implementations

impl HttpClient

pub fn new(config: HttpConfig) -> Result<Self>

Creates a new HTTP client with the given configuration.

Arguments

• config - HTTP client configuration

Returns

Returns a Result containing the initialized client or an error if client creation fails.

Errors

Returns an error if:

• The proxy URL is invalid
• The HTTP client cannot be built

pub fn new_with_rate_limiter( config: HttpConfig, rate_limiter: RateLimiter, ) -> Result<Self>

Creates a new HTTP client with a custom rate limiter.

Arguments

• config - HTTP client configuration
• rate_limiter - Pre-configured rate limiter instance

Returns

Returns a Result containing the initialized client with rate limiter.

Errors

Returns an error if client creation fails.

pub fn set_rate_limiter(&mut self, rate_limiter: RateLimiter)

Sets the rate limiter for this client.

Arguments

• rate_limiter - Rate limiter instance to use

pub fn set_retry_strategy(&mut self, strategy: RetryStrategy)

Sets the retry strategy for this client.

Arguments

• strategy - Retry strategy to use for failed requests

pub fn set_circuit_breaker(&mut self, circuit_breaker: Arc<CircuitBreaker>)

Sets the circuit breaker for this client.

Arguments

• circuit_breaker - Circuit breaker instance to use

Example

use ccxt_core::http_client::{HttpClient, HttpConfig};
use ccxt_core::circuit_breaker::{CircuitBreaker, CircuitBreakerConfig};
use std::sync::Arc;

let mut client = HttpClient::new(HttpConfig::default()).unwrap();
let cb = Arc::new(CircuitBreaker::new(CircuitBreakerConfig::default()));
client.set_circuit_breaker(cb);

pub fn circuit_breaker(&self) -> Option<&Arc<CircuitBreaker>>

Returns a reference to the circuit breaker, if configured.

This can be used to check the circuit breaker state or manually record success/failure.

pub fn config(&self) -> &HttpConfig

Returns a reference to current HTTP configuration.

pub fn set_config(&mut self, config: HttpConfig)

Updates the HTTP configuration.

Arguments

• config - New configuration to use

impl HttpClient

pub async fn fetch( &self, url: &str, method: Method, headers: Option<HeaderMap>, body: Option<Value>, ) -> Result<Value>

Executes an HTTP request with automatic retry mechanism and timeout control.

The entire retry flow is wrapped with tokio::time::timeout to ensure that the total operation time (including all retries) does not exceed the configured timeout.

Arguments

• url - Target URL for the request
• method - HTTP method to use
• headers - Optional custom headers
• body - Optional request body as JSON

Returns

Returns the response body as a JSON Value.

Errors

Returns an error if:

• The operation times out (including all retries)
• All retry attempts fail
• The server returns an error status code
• Network communication fails

pub async fn get(&self, url: &str, headers: Option<HeaderMap>) -> Result<Value>

Executes a GET request.

Arguments

• url - Target URL
• headers - Optional custom headers

Returns

Returns the response body as a JSON Value.

Errors

Returns an error if the request fails.

pub async fn post( &self, url: &str, headers: Option<HeaderMap>, body: Option<Value>, ) -> Result<Value>

Executes a POST request.

Arguments

• url - Target URL
• headers - Optional custom headers
• body - Optional request body as JSON

Returns

Returns the response body as a JSON Value.

Errors

Returns an error if the request fails.

pub async fn put( &self, url: &str, headers: Option<HeaderMap>, body: Option<Value>, ) -> Result<Value>

Executes a PUT request.

Arguments

• url - Target URL
• headers - Optional custom headers
• body - Optional request body as JSON

Returns

Returns the response body as a JSON Value.

Errors

Returns an error if the request fails.

pub async fn delete( &self, url: &str, headers: Option<HeaderMap>, body: Option<Value>, ) -> Result<Value>

Executes a DELETE request.

Arguments

• url - Target URL
• headers - Optional custom headers
• body - Optional request body as JSON

Returns

Returns the response body as a JSON Value.

Errors

Returns an error if the request fails.

Trait Implementations

impl Debug for HttpClient

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

Formats the value using the given formatter.