pub struct SessionSweepConfig {
pub interval: Duration,
pub tx_warn_secs: Duration,
pub tx_max_age_secs: Duration,
}Expand description
ADR-091 Amendment 2 Plank A: config for the observe-only per-session
sweep. Sessions never checkpoint — that stays daemon-owned so N session
processes never compete for the writer mutex — this only watches
tx_registry (and, Plank B, refreshes this process’s walpin heartbeat).
Fields§
§interval: DurationHow often a session polls the registry. Coarser than the daemon’s tick: sessions do not need the daemon’s 500ms checkpoint cadence.
Overridable via KHIVE_SESSION_SWEEP_INTERVAL_MS. Default: 5000 ms.
tx_warn_secs: DurationSame semantics and default as CheckpointConfig::tx_warn_secs.
tx_max_age_secs: DurationSame semantics and default as CheckpointConfig::tx_max_age_secs.
Implementations§
Trait Implementations§
Source§impl Clone for SessionSweepConfig
impl Clone for SessionSweepConfig
Source§fn clone(&self) -> SessionSweepConfig
fn clone(&self) -> SessionSweepConfig
Returns a duplicate of the value. Read more
1.0.0 (const: unstable) · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source. Read moreSource§impl Debug for SessionSweepConfig
impl Debug for SessionSweepConfig
Auto Trait Implementations§
impl Freeze for SessionSweepConfig
impl RefUnwindSafe for SessionSweepConfig
impl Send for SessionSweepConfig
impl Sync for SessionSweepConfig
impl Unpin for SessionSweepConfig
impl UnsafeUnpin for SessionSweepConfig
impl UnwindSafe for SessionSweepConfig
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
Source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self>
fn into_either(self, into_left: bool) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left is true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left(&self) returns true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read more