brk_fetcher 0.11.2

A Bitcoin price fetcher
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

use std::{thread::sleep, time::Duration};

use brk_error::Result;
use tracing::info;

pub fn default_retry<T>(function: impl Fn(usize) -> Result<T>) -> Result<T> {
    retry(function, 5, 6)
}

fn retry<T>(function: impl Fn(usize) -> Result<T>, sleep_in_s: u64, retries: usize) -> Result<T> {
    let mut i = 0;

    loop {
        let res = function(i);

        if res.is_ok() {
            return res;
        }

        // Check if error is permanent (blocked endpoint, DNS failure, etc.)
        // If so, fail immediately without retrying
        if let Err(ref e) = res
            && e.is_network_permanently_blocked()
        {
            info!("Permanent network error detected (blocked/unreachable), skipping retries");
            return res;
        }

        if i == retries {
            return res;
        }

        info!("Failed, waiting {sleep_in_s} seconds...");
        sleep(Duration::from_secs(sleep_in_s));

        i += 1;
    }
}