orbit-client-pool 0.5.5

Protocol-neutral local and fleet-wide outbound client pools for Orbit process fleets.
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

use std::sync::Arc;

/// Admission consequence derived from one protocol-specific outcome.
///
/// This type deliberately contains no HTTP status, header, retry, or decoding
/// knowledge. The application returns its own error to the triggering caller,
/// then may apply `Pause` to stop later acquisitions until it repairs the
/// profile and explicitly resumes the pool.
#[derive(Clone, Debug, Eq, PartialEq)]
pub enum PoolDirective {
    Continue,
    Pause { reason: Arc<str> },
}

impl PoolDirective {
    pub fn pause(reason: impl Into<Arc<str>>) -> Self {
        Self::Pause { reason: reason.into() }
    }
}

/// Application-owned classification from a domain outcome to pool admission.
///
/// `O` may be an HTTP response, a protocol frame, or an application result.
/// The pool never decodes it.
pub trait ClientPolicy<O>: Send + Sync {
    fn classify(
        &self,
        outcome: &O,
    ) -> PoolDirective;
}