pub struct GlobalFailurePolicy {
pub connect_attempts: u32,
pub connect_timeout: Duration,
pub retry_backoff: Duration,
pub request_timeout: Duration,
pub collective_timeout: Duration,
}Expand description
Startup retry is safe only before a request is submitted. Failed collectives are never replayed: discard the communicator and register a fresh group.
Fields§
§connect_attempts: u32Maximum connection attempts per control channel, including the first.
connect_timeout: DurationPer-attempt connection and handshake limit.
retry_backoff: DurationInitial retry backoff, doubled with a five-second cap.
request_timeout: DurationTotal bound for a queued control request and its reply.
collective_timeout: DurationTotal bound for a collective, including local serialization and sync.
Implementations§
Source§impl GlobalFailurePolicy
impl GlobalFailurePolicy
Sourcepub fn from_environment() -> Result<Self, String>
pub fn from_environment() -> Result<Self, String>
Environment overrides are validated instead of enabling infinite waits.
Trait Implementations§
Source§impl Clone for GlobalFailurePolicy
impl Clone for GlobalFailurePolicy
impl Copy for GlobalFailurePolicy
Source§impl Debug for GlobalFailurePolicy
impl Debug for GlobalFailurePolicy
Auto Trait Implementations§
impl Freeze for GlobalFailurePolicy
impl RefUnwindSafe for GlobalFailurePolicy
impl Send for GlobalFailurePolicy
impl Sync for GlobalFailurePolicy
impl Unpin for GlobalFailurePolicy
impl UnsafeUnpin for GlobalFailurePolicy
impl UnwindSafe for GlobalFailurePolicy
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more