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
51
52
53
54
55
56
57
58

use std::time::Duration;

use reqx::prelude::{Client, RetryPolicy};
use serde::{Deserialize, Serialize};

#[derive(Debug, Serialize)]
struct CreateItem<'a> {
    name: &'a str,
    enabled: bool,
}

#[derive(Debug, Deserialize)]
struct EchoResponse {
    json: Option<serde_json::Value>,
}

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
    let client = Client::builder("https://postman-echo.com")
        .client_name("reqx-example-basic")
        .request_timeout(Duration::from_secs(3))
        .total_timeout(Duration::from_secs(10))
        .retry_policy(
            RetryPolicy::standard()
                .max_attempts(3)
                .base_backoff(Duration::from_millis(100))
                .max_backoff(Duration::from_millis(800)),
        )
        .build()?;

    let ping = client
        .get("/get")
        .query_pair("from", "reqx")
        .query_pair("lang", "zh")
        .send()
        .await?;

    println!(
        "GET /get => status={} body_bytes={}",
        ping.status(),
        ping.body().len()
    );

    let payload = CreateItem {
        name: "demo",
        enabled: true,
    };

    let echoed: EchoResponse = client
        .post("/post")
        .idempotency_key("create-item-001")?
        .json(&payload)?
        .send_json()
        .await?;

    println!("POST /post => echoed_json={:?}", echoed.json);
    Ok(())
}