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
//! Retry sending records configuration. /// You can calculate retrying interval as the following equation: /// /// `retry_interval = exp ** (multiplier + retry_counts)` /// /// see: https://github.com/jimmycuadra/retry/blob/v0.4.0/src/lib.rs#L142-L143 /// /// You can estimate to caluculate with concrete values like: /// /// * retry_counts: 10, e ^ (5 + 10)/1000.0/60.0/60.0 = 0.908060381242253, about 0.9 hour /// /// * retry_counts: 11, e ^ (5 + 11)/1000.0/60.0/60.0 = 2.4683640334744092, about 2.5 hours /// /// * retry_counts: 12, e ^ (5 + 12)/1000.0/60.0/60.0 = 6.709709098215361, about 6.7 hours /// /// where multiplier = 5, /// e is [exponential function](https://doc.rust-lang.org/std/primitive.f64.html#method.exp). /// /// ## Default values /// /// * multiplier: 5_f64 /// * max: 10 #[derive(Debug, Clone, PartialEq)] pub struct RetryConf { max: u64, multiplier: f64, } impl Default for RetryConf { fn default() -> RetryConf { RetryConf { max: 10, multiplier: 5_f64, } } } impl RetryConf { pub fn new() -> RetryConf { Default::default() } pub fn max(mut self, max: u64) -> RetryConf { self.max = max; self } pub fn multiplier(mut self, multiplier: f64) -> RetryConf { self.multiplier = multiplier; self } pub fn build(self) -> (u64, f64) { (self.max, self.multiplier) } }