async_repeat 0.1.0

Retry futures mechanism
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

use async_retry::{AsyncRetry, LinearRetryStrategy, RetryPolicy};
use reqwest::{IntoUrl, Response, StatusCode};
use std::time::Duration;

async fn make_request<T: IntoUrl>(url: T) -> Result<Response, RetryPolicy<String>> {
    let resp = reqwest::get(url).await?;
    if resp.status() == StatusCode::BAD_REQUEST {
        Err(RetryPolicy::Fail(String::from("Cannot recover from bad request")))
    } else if resp.status() == StatusCode::INTERNAL_SERVER_ERROR {
        Err(RetryPolicy::Repeat(None))
    } else {
        Ok(resp)
    }
}

#[tokio::main]
async fn main() -> anyhow::Result<()> {
    let url = "http://localhost:8084";
    let resp = AsyncRetry::new(
        || make_request(url),
        LinearRetryStrategy::default()
            .delay_between_repeats(Duration::from_secs(5))
            .max_attempts(2),
    )
    .await?;

    eprintln!("resp = {:#?}", resp);

    Ok(())
}