qubit-retry 0.9.2

Retry module, providing a feature-complete, type-safe retry management system with support for multiple delay strategies and event listeners
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

/*******************************************************************************
 *
 *    Copyright (c) 2025 - 2026.
 *    Haixing Hu, Qubit Co. Ltd.
 *
 *    All rights reserved.
 *
 ******************************************************************************/
//! `parse_display` bridge for [`std::time::Duration`] fields on
//! [`RetryDelay`](crate::RetryDelay).
//!
//! See [`RetryDelay`](crate::RetryDelay) for the full text form; this type only
//! wires each duration field to [`qubit_common::serde::duration_with_unit`].

use std::fmt;
use std::time::Duration;

use parse_display::{DisplayFormat, FromStrFormat, ParseError};
use qubit_common::serde::duration_with_unit;

/// Bridges `parse_display` for [`Duration`] fields to [`duration_with_unit`].
/// `regex` returns `None` so the default non-greedy `.*?` capture is used, which
/// supports multi-unit text and characters such as `µ` in `µs` (unlike a strict ASCII token).
pub(crate) struct RetryDelayDurationFormat;

impl DisplayFormat<Duration> for RetryDelayDurationFormat {
    /// Same output as [`duration_with_unit::format`]: saturated whole milliseconds and `ms`.
    fn write(&self, f: &mut fmt::Formatter<'_>, value: &Duration) -> fmt::Result {
        f.write_str(&duration_with_unit::format(value))
    }
}

impl FromStrFormat<Duration> for RetryDelayDurationFormat {
    type Err = ParseError;

    /// Uses [`duration_with_unit::parse`]. Dynamic parse errors are collapsed to a
    /// fixed [`parse_display::ParseError`] because its message is `&'static str` only.
    fn parse(&self, s: &str) -> Result<Duration, Self::Err> {
        duration_with_unit::parse(s).map_err(|_| {
            ParseError::with_message(
                "invalid retry delay duration: expected a value accepted by `duration_with_unit`",
            )
        })
    }

    fn regex(&self) -> Option<String> {
        None
    }
}