obix 0.2.22

Implementation of outbox backed by PG / sqlx
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

use es_entity::clock::{Clock, ClockHandle};
use job::{JobType, RetrySettings};

use std::time::Duration;

#[derive(Clone)]
pub struct InboxConfig {
    pub job_type: JobType,
    pub retry_settings: RetrySettings,
    pub clock: ClockHandle,
}

impl InboxConfig {
    pub fn new(job_type: JobType) -> Self {
        Self {
            job_type,
            retry_settings: RetrySettings::default(),
            clock: Clock::handle().clone(),
        }
    }

    pub fn with_retry_settings(mut self, settings: RetrySettings) -> Self {
        self.retry_settings = settings;
        self
    }

    /// Set max attempts before dead-lettering
    pub fn with_max_attempts(mut self, n: u32) -> Self {
        self.retry_settings.n_attempts = Some(n);
        self
    }

    /// Set backoff bounds
    pub fn with_backoff(mut self, min: Duration, max: Duration) -> Self {
        self.retry_settings.min_backoff = min;
        self.retry_settings.max_backoff = max;
        self
    }

    /// Set jitter percentage (0-100)
    pub fn with_jitter(mut self, pct: u8) -> Self {
        self.retry_settings.backoff_jitter_pct = pct;
        self
    }

    pub fn with_clock(mut self, clock: ClockHandle) -> Self {
        self.clock = clock;
        self
    }
}