Struct RetryManager 

pub struct RetryManager { /* private fields */ }

Centralized retry and reconnection management with backoff, jitter, and authentication

Implementations

impl RetryManager

pub fn new( max_retries: usize, base_backoff_ms: u64, max_backoff_ms: u64, ) -> Self

pub fn max_retries(&self) -> usize

Get the maximum number of retries

pub async fn insert_auth_token<T>( client: &DanubeClient, request: &mut Request<T>, addr: &Uri, ) -> Result<()>

Insert authentication token into request. Delegates to [AuthService::insert_token_if_needed].

pub fn insert_proxy_header<T>( request: &mut Request<T>, broker_url: &Uri, proxy: bool, )

Insert proxy routing header into request when proxy mode is active. The proxy uses this header to route the gRPC call to the correct broker.

pub fn is_retryable_error(&self, error: &DanubeError) -> bool

Check if an error is retryable based on gRPC status codes.

Retryable codes:

• Unavailable — broker not reachable or topic moved (ServiceNotReady)
• DeadlineExceeded — request timed out
• ResourceExhausted — rate limited / overloaded

pub fn calculate_backoff(&self, attempt: usize) -> Duration

Calculate linear backoff with jitter

Trait Implementations

impl Clone for RetryManager

fn clone(&self) -> RetryManager

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for RetryManager

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.