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
37
38
39
40
41
42
43
44
45
46
47
48
49
50

use std::sync::Arc;
use std::time::Duration;

use http::StatusCode;
use reqx::advanced::{RetryClassifier, RetryDecision, RetryReason};
use reqx::prelude::{Client, RetryPolicy};

struct RetryOn429Only;

impl RetryClassifier for RetryOn429Only {
    fn should_retry(&self, decision: &RetryDecision) -> bool {
        matches!(
            decision.reason(),
            RetryReason::Status(StatusCode::TOO_MANY_REQUESTS)
        )
    }
}

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
    let retry_policy = RetryPolicy::standard()
        .max_attempts(3)
        .base_backoff(Duration::from_millis(50))
        .max_backoff(Duration::from_millis(200))
        .jitter_ratio(0.0)
        .retry_classifier(Arc::new(RetryOn429Only));

    let client = Client::builder("https://postman-echo.com")
        .client_name("reqx-example-retry-classifier")
        .request_timeout(Duration::from_secs(3))
        .retry_policy(retry_policy)
        .build()?;

    let result = client
        .get("/status/429")
        .send()
        .await
        .map(|response| response.status().as_u16());

    match result {
        Ok(status) => {
            println!("unexpected success: status={status}");
        }
        Err(error) => {
            println!("request failed after classifier-based retries: {error}");
        }
    }

    Ok(())
}