reqx 0.1.35

Rust HTTP transport client for API SDK libraries with retry, timeout, idempotency, proxy, and pluggable TLS backends
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36

use std::time::Duration;

use reqx::prelude::{Client, RetryPolicy};

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
    let client = Client::builder("https://postman-echo.com")
        .client_name("reqx-example-metrics")
        .request_timeout(Duration::from_secs(3))
        .retry_policy(RetryPolicy::standard().max_attempts(2))
        .metrics_enabled(true)
        .build()?;

    let _ = client.get("/status/200").send().await;
    let _ = client.get("/status/503").send().await;

    let metrics = client.metrics_snapshot();
    println!(
        "started={} succeeded={} failed={} retries={}",
        metrics.requests.started,
        metrics.requests.succeeded,
        metrics.requests.failed,
        metrics.requests.retries
    );
    println!(
        "timeout_transport={} timeout_response_body={} in_flight={} avg_latency_ms={:.2}",
        metrics.timeouts.transport,
        metrics.timeouts.response_body,
        metrics.requests.in_flight,
        metrics.latency.average_ms
    );
    println!("status_counts={:?}", metrics.responses.status_counts);
    println!("errors_by_code={:?}", metrics.errors.by_code);

    Ok(())
}