reqx 0.1.35

Rust HTTP transport client for API SDK libraries with retry, timeout, idempotency, proxy, and pluggable TLS backends
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

use std::time::Duration;

use crate::policy::RequestContext;
use crate::rate_limit::ServerThrottleScope;
use crate::retry::RetryDecision;

/// Passive observer for request lifecycle events.
pub trait Observer: Send + Sync {
    /// Called when a request attempt starts.
    fn on_request_start(&self, _context: &RequestContext) {}

    /// Called when a retry has been scheduled.
    fn on_retry_scheduled(
        &self,
        _context: &RequestContext,
        _decision: &RetryDecision,
        _delay: Duration,
    ) {
    }

    /// Called when the client honors a server throttling hint.
    fn on_server_throttle(
        &self,
        _context: &RequestContext,
        _scope: ServerThrottleScope,
        _delay: Duration,
    ) {
    }
}