Struct RestClient 

pub struct RestClient { /* private fields */ }

Main REST client with connection pooling via ureq Agent

The RestClient uses ureq’s Agent for automatic connection pooling and reuse. Cloning the client is cheap - it shares the same connection pool.

Connection Pooling

The underlying ureq Agent maintains a connection pool that:

• Reuses TCP connections across multiple requests
• Reduces connection overhead for subsequent requests
• Automatically handles connection lifecycle

Thread Safety

The RestClient is NOT Send/Sync due to ureq::Agent implementation. For multi-threaded usage, create a separate client per thread.

Implementations

impl RestClient

pub fn new(auth: Auth) -> RestClient

Create a new REST client with authentication

Example

use marketdata_core::{RestClient, Auth};

let client = RestClient::new(Auth::SdkToken("my-token".to_string()));

pub fn with_tls( auth: Auth, tls: TlsConfig, ) -> Result<RestClient, MarketDataError>

Create a REST client with custom TLS configuration (custom root CA or “accept invalid certs”). Prefer new() for production usage against public Fugle endpoints.

Returns a ConfigError if the PEM in tls.root_cert_pem is malformed.

Errors

Returns MarketDataError on transport, deserialization, validation, or non-2xx API failures.

pub fn with_retry(self, policy: RetryPolicy) -> RestClient

Enable transparent retry of failed requests.

By default the client does not retry — observability use cases need real failures visible. With a RetryPolicy installed, errors for which MarketDataError::is_retryable returns true (HTTP 429, HTTP 5xx, transport timeouts and connection errors) are retried with exponential backoff plus jitter, up to max_attempts total attempts. Other errors propagate immediately.

Example

use marketdata_core::{Auth, RestClient, RetryPolicy};

let client = RestClient::new(Auth::SdkToken("t".into()))
    .with_retry(RetryPolicy::conservative());

pub fn base_url(self, url: &str) -> RestClient

Override the base URL (useful for testing or custom endpoints)

Example

use marketdata_core::{RestClient, Auth};

let client = RestClient::new(Auth::SdkToken("my-token".to_string()))
    .base_url("https://custom.api.example.com");

pub fn stock(&self) -> StockClient<'_>

Access stock-related endpoints

Example

use marketdata_core::{RestClient, Auth};

let client = RestClient::new(Auth::SdkToken("my-token".to_string()));
let stock_client = client.stock();

pub fn futopt(&self) -> FutOptClient<'_>

Access FutOpt (futures and options) endpoints

Example

use marketdata_core::{RestClient, Auth};

let client = RestClient::new(Auth::SdkToken("my-token".to_string()));
let futopt_client = client.futopt();

Trait Implementations

impl Clone for RestClient

fn clone(&self) -> RestClient

Clone the RestClient, sharing the same connection pool

Cloning is cheap because ureq::Agent internally uses Arc for connection pool sharing. Multiple cloned clients will share the same connection pool.

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

Performs copy-assignment from source.