Struct RetentionPolicy 

pub struct RetentionPolicy {
    pub ttl_completed_secs: u64,
    pub ttl_failed_secs: u64,
    pub max_executions: u64,
    pub max_journal_bytes: u64,
    pub prune_batch_size: u64,
    pub prune_interval_secs: u64,
    pub stale_running_after_secs: u64,
}

Journal retention and compaction policy ([durable.retention]).

Drives the background prune sweep, which never runs on the dispatch hot path.

Examples

use zeph_config::RetentionPolicy;

let policy = RetentionPolicy::default();
assert_eq!(policy.ttl_completed_secs, 604_800); // 7 days
assert_eq!(policy.ttl_failed_secs, 2_592_000); // 30 days

Fields

ttl_completed_secs: u64

Prune completed executions older than this, in seconds.

ttl_failed_secs: u64

Prune failed or aborted executions older than this, in seconds.

max_executions: u64

LRU cap on the number of stored executions.

max_journal_bytes: u64

Size cap on the journal in bytes; exceeding it triggers an LRU sweep.

prune_batch_size: u64

Rows deleted per transaction during a prune sweep; the task yields between batches.

prune_interval_secs: u64

Background prune poll interval, in seconds.

stale_running_after_secs: u64

Crash-orphan threshold, in seconds (#6254): a status='running' row whose updated_at is older than this becomes a sweep candidate, subject to an INV-15 flock liveness check before it is aborted. 0 disables the sweep entirely.

Trait Implementations

impl Clone for RetentionPolicy

fn clone(&self) -> RetentionPolicy

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for RetentionPolicy

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

Formats the value using the given formatter.

impl Default for RetentionPolicy

fn default() -> RetentionPolicy

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for RetentionPolicy

where RetentionPolicy: Default,

fn deserialize<__D>( __deserializer: __D, ) -> Result<RetentionPolicy, <__D as Deserializer<'de>>::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Eq for RetentionPolicy

impl PartialEq for RetentionPolicy

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

Equality operator ==.

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

Inequality operator !=.

impl Serialize for RetentionPolicy

fn serialize<__S>( &self, __serializer: __S, ) -> Result<<__S as Serializer>::Ok, <__S as Serializer>::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for RetentionPolicy