integrationos-domain 8.0.0

Shared library for IntegrationOS
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

use crate::{IntegrationOSError, InternalError};
use serde::{Deserialize, Serialize};
use std::time::Duration;

#[derive(Debug, Serialize, Deserialize, Clone, Eq, PartialEq)]
#[cfg_attr(feature = "dummy", derive(fake::Dummy))]
pub struct Policies {
    pub retry: RetryPolicy,
}

#[derive(Debug, Clone, Eq, PartialEq, Serialize, Deserialize)]
#[cfg_attr(feature = "dummy", derive(fake::Dummy))]
#[serde(rename_all = "camelCase")]
pub struct RetryPolicy {
    #[cfg_attr(feature = "dummy", dummy(faker = "0..10"))]
    pub maximum_attempts: u64,
    pub initial_interval: String,
}

impl RetryPolicy {
    pub fn get_interval(&self) -> Result<Duration, IntegrationOSError> {
        let mut parts = self.initial_interval.split(' ');
        let num = parts
            .next()
            .ok_or(InternalError::configuration_error(
                "No number in retry policy interval",
                None,
            ))?
            .parse()
            .map_err(|e| {
                InternalError::configuration_error(
                    &format!("Invalid retry policy interval number: {}", e),
                    None,
                )
            })?;
        let amount = parts.next().ok_or(InternalError::configuration_error(
            "No amount in retry policy interval",
            None,
        ))?;
        match amount {
            "seconds" | "second" => Ok(Duration::from_secs(num)),
            "minute" | "minutes" => Ok(Duration::from_secs(num * 60)),
            x => Err(InternalError::configuration_error(
                &format!("Invalid retry policy interval amount: {}", x),
                None,
            )),
        }
    }
}