Struct Policy 

pub struct Policy {
    pub debounce: Duration,
    pub on_error: StoreOnError,
    pub retries: u32,
    pub max_value_bytes: Option<u64>,
}

The checkpoint policy knobs (store.checkpoint, store.durability, store.on_error).

Fields

debounce: Duration

on_error: StoreOnError

retries: u32

max_value_bytes: Option<u64>

Refuse a durable write whose serialized envelope exceeds this many bytes (store.max_value_bytes; None = unbounded, the default).

This exists because a store’s WRITE limit and its READ limit need not be the same number. An MCP-backed store reached through a broker can accept a value on the way in and be unable to return it on the way out — at which point the checkpoint is stranded: the write succeeded, and the next BOOT RESTORE is what fails, when the agent is least able to do anything about it. Refusing at write time keeps the failure where an operator is looking and where store.on_error can act on it.

Implementations

impl Policy

pub fn from_settings(s: &Store) -> Policy

Trait Implementations

impl Clone for Policy

fn clone(&self) -> Policy

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Policy

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

Formats the value using the given formatter.

impl Default for Policy

fn default() -> Self

Returns the “default value” for a type.