flowmium 0.0.9

Flowmium is a workflow orchestrator that use Kubernetes
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::{future::Future, time::Duration};

pub(crate) async fn with_exp_backoff_retry<T, F>(
    operation: impl Fn() -> F,
    retry_message: &'static str,
    max_retry_count: i32,
) -> Option<T>
where
    F: Future<Output = Option<T>>,
{
    let mut backoff_counter = 500;
    let mut retry_count = 0;

    loop {
        match operation().await {
            Some(some_val) => break Some(some_val),
            None => {
                retry_count += 1;
                backoff_counter *= 2;

                match retry_count > max_retry_count {
                    true => break None,
                    false => {
                        tracing::info!(
                            "{} retrying with backoff for {} milliseconds",
                            retry_message,
                            backoff_counter
                        );

                        tokio::time::sleep(Duration::from_millis(backoff_counter)).await
                    }
                }
            }
        };
    }
}