Struct BreakerConfig 

#[non_exhaustive]
pub struct BreakerConfig {
    pub failure_threshold: u32,
    pub open_for: Duration,
    pub half_open_probes: u32,
}

Per-replica circuit breaker thresholds.

Fields (Non-exhaustive)

Non-exhaustive structs could have additional fields added in future. Therefore, non-exhaustive structs cannot be constructed in external crates using the traditional Struct { .. } syntax; cannot be matched against without a wildcard ..; and struct update syntax will not work.

failure_threshold: u32

Consecutive failures that open the breaker, quarantining that endpoint.

open_for: Duration

How long an open breaker rejects a replica before probing again.

Also bounds how long a batch parked behind a fully-probing shard waits before re-checking of its own accord (clamped to [100ms, 30s]). Capped at a year on the way in: it is stamped into a deadline, and Instant + Duration panics rather than saturating.

half_open_probes: u32

Concurrent probe writes allowed while half-open.

Must be at least 1; validate rejects 0, which taken literally would mean the replica never recovers. The breaker also floors it at 1 at the point of use, so a config built programmatically rather than loaded cannot wedge a replica either.

Implementations

impl BreakerConfig

pub const MAX_OPEN_FOR: Duration

Ceiling on open_for.

It is stamped into a deadline, and Instant + Duration panics rather than saturating. A year already means “never probe again”, so anything beyond it is a typo rather than a policy.

pub fn validate(&self) -> Result<(), BreakerConfigError>

Reject breaker thresholds that would misbehave at runtime.

The companion to RetryConfig::validate, called from the same place for the same reason: the rules stay here instead of being mirrored per connector.

Errors

BreakerConfigError, naming the offending key.

use spate_core::sink::{BreakerConfig, BreakerConfigError};

assert!(BreakerConfig::default().validate().is_ok());

let mut wedged = BreakerConfig::default();
wedged.half_open_probes = 0;
assert_eq!(wedged.validate(), Err(BreakerConfigError::ZeroHalfOpenProbes));

Trait Implementations

impl Clone for BreakerConfig

fn clone(&self) -> BreakerConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Copy for BreakerConfig

impl Debug for BreakerConfig

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

Formats the value using the given formatter.

impl Default for BreakerConfig

fn default() -> Self

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for BreakerConfig

where BreakerConfig: Default,

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Eq for BreakerConfig

impl PartialEq for BreakerConfig

fn eq(&self, other: &BreakerConfig) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl StructuralPartialEq for BreakerConfig