memable 0.1.4

An embeddable durable execution engine using key-based memoisation
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
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
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113

use std::time::Duration;

/// Configures automatic retry behavior for a step.
///
/// When a step closure returns [`StepError::Retryable`](crate::StepError::Retryable),
/// the engine retries the closure according to this policy. Permanent errors
/// bypass retries entirely.
///
/// # Examples
///
/// ```
/// use std::time::Duration;
/// use memable::RetryPolicy;
///
/// // Retry up to 3 times with 1-second fixed delay.
/// let fixed = RetryPolicy::fixed(3, Duration::from_secs(1));
///
/// // Retry up to 5 times with exponential backoff (1s, 2s, 4s, 8s, 16s).
/// let expo = RetryPolicy::exponential(5, Duration::from_secs(1));
///
/// // Cap exponential delay at 10 seconds.
/// let capped = RetryPolicy::exponential(5, Duration::from_secs(1))
///     .with_max_delay(Duration::from_secs(10));
/// ```
#[derive(Debug, Clone)]
pub struct RetryPolicy {
    pub(crate) max_retries: u32,
    pub(crate) backoff: Backoff,
}

#[derive(Debug, Clone)]
pub(crate) enum Backoff {
    Fixed(Duration),
    Exponential { base: Duration, max: Duration },
}

impl RetryPolicy {
    /// Creates a policy with a fixed delay between attempts.
    ///
    /// # Examples
    ///
    /// ```
    /// use std::time::Duration;
    /// use memable::RetryPolicy;
    ///
    /// let policy = RetryPolicy::fixed(3, Duration::from_secs(1));
    /// ```
    #[must_use]
    pub fn fixed(max_retries: u32, delay: Duration) -> Self {
        Self {
            max_retries,
            backoff: Backoff::Fixed(delay),
        }
    }

    /// Creates a policy with exponential backoff.
    ///
    /// Delay doubles each attempt: `base`, `2*base`, `4*base`, etc.,
    /// capped at 30 seconds by default. Use [`with_max_delay`](Self::with_max_delay)
    /// to change the cap.
    ///
    /// # Examples
    ///
    /// ```
    /// use std::time::Duration;
    /// use memable::RetryPolicy;
    ///
    /// let policy = RetryPolicy::exponential(3, Duration::from_secs(1));
    /// ```
    #[must_use]
    pub fn exponential(max_retries: u32, base: Duration) -> Self {
        Self {
            max_retries,
            backoff: Backoff::Exponential {
                base,
                max: Duration::from_secs(30),
            },
        }
    }

    /// Sets the maximum delay for exponential backoff.
    ///
    /// Has no effect on fixed-delay policies.
    ///
    /// # Examples
    ///
    /// ```
    /// use std::time::Duration;
    /// use memable::RetryPolicy;
    ///
    /// let policy = RetryPolicy::exponential(5, Duration::from_secs(1))
    ///     .with_max_delay(Duration::from_secs(10));
    /// ```
    #[must_use]
    pub fn with_max_delay(mut self, max: Duration) -> Self {
        if let Backoff::Exponential { max: ref mut m, .. } = self.backoff {
            *m = max;
        }
        self
    }

    /// Returns the delay before the given retry attempt (0-indexed).
    pub(crate) fn delay_for(&self, attempt: u32) -> Duration {
        match self.backoff {
            Backoff::Fixed(d) => d,
            Backoff::Exponential { base, max } => {
                let multiplier = 1u64.checked_shl(attempt).unwrap_or(u64::MAX);
                let delay = base.saturating_mul(multiplier.try_into().unwrap_or(u32::MAX));
                delay.min(max)
            }
        }
    }
}