rexcli 0.18.4

Replix admin CLI tool
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
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78

//
// Copyright (c) 2020 RepliXio Ltd. All rights reserved.
// Use is subject to license terms.
//

use std::time::Duration;

use crate::latest;

pub(crate) fn stepping_down_delay(initial: Duration) -> BackOn {
    BackOn::new(initial)
}

pub(crate) struct BackOn {
    next: Duration,
    min: Duration,
}

impl BackOn {
    pub(crate) fn new(initial: Duration) -> Self {
        let next = initial;
        let min = Duration::from_secs_f32(1.5);
        Self { next, min }
    }
}

impl Iterator for BackOn {
    type Item = Duration;
    fn next(&mut self) -> Option<Self::Item> {
        let next = self.next;
        let millis = 500 + rand::random::<u64>() % 1000;
        let step = Duration::from_millis(millis);
        self.next = std::cmp::max(self.next - step, self.min);
        Some(next)
    }
}

impl crate::RealmSpec {
    pub(crate) fn to_api(&self) -> latest::RealmTypeCreate {
        match self.clone() {
            Self::Aws {
                role_arn,
                external_id,
            } => latest::RealmTypeCreate::Aws {
                r#type: "aws".to_owned(),
                role_arn,
                external_id,
            },
            Self::Azure {
                subscription_id,
                tenant_id,
                client_id,
                client_secret,
            } => latest::RealmTypeCreate::Azure {
                r#type: "azure".to_owned(),
                subscription_id,
                tenant_id,
                client_id,
                client_secret,
            },
        }
    }
}

impl latest::SnapshotExportCreate {
    pub(crate) fn aws(realm: impl AsRef<str>, region: impl AsRef<str>) -> Self {
        let realm = realm.as_ref().to_string();
        let region = region.as_ref().to_string();
        let aws = latest::AwsSnapshotExportCreate { realm, region };
        Self::Aws(aws)
    }
}

impl latest::SnapshotExport {
    pub(crate) fn aws_snapshot_id(&self) -> Option<String> {
        None
    }
}