Struct PromotionPolicy 

pub struct PromotionPolicy {
    pub idle_after: Duration,
    pub sweep_interval: Option<Duration>,
}

Tunables for when buffered writes get promoted to CAS.

Fields

idle_after: Duration

Drain buffers with no writes for at least this long. The check runs opportunistically on every mutating call; agents that go quiet without closing aren’t left holding the buffer.

sweep_interval: Option<Duration>

How often the clock-driven safety-sweep thread wakes up to drain idle buffers. None disables the timer entirely (useful for tests that want deterministic event-driven promotion).

Trait Implementations

impl Clone for PromotionPolicy

fn clone(&self) -> PromotionPolicy

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Copy for PromotionPolicy

impl Debug for PromotionPolicy

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

Formats the value using the given formatter.

impl Default for PromotionPolicy

fn default() -> Self

Returns the “default value” for a type.