resilient 0.1.0

A Rust resilience library providing retry, circuit breaker, timeout, bulkhead, and rate limiting policies
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

use resilient::RetryPolicy;
use std::sync::atomic::{AtomicU32, Ordering};
use std::sync::Arc;

#[tokio::main]
async fn main() {
    let policy = RetryPolicy::default().with_max_retries(3);
    let attempts = Arc::new(AtomicU32::new(0));

    let result: Result<String, String> = policy
        .run(|| {
            let a = attempts.clone();
            async move {
                let n = a.fetch_add(1, Ordering::Relaxed);
                if n < 2 {
                    Err(format!("attempt {} failed", n + 1))
                } else {
                    Ok("finally succeeded!".to_string())
                }
            }
        })
        .await;

    println!("{:?}", result);
}