Struct RetentionPolicyEngine 

pub struct RetentionPolicyEngine {
    pub config: PolicyConfig,
    pub stats: RetentionEngineStats,
}

Engine that evaluates block retention decisions against a PolicyConfig.

Fields

config: PolicyConfig

Policy configuration driving all evaluations.

stats: RetentionEngineStats

Running statistics since the last reset_stats().

Implementations

impl RetentionPolicyEngine

pub fn new(config: PolicyConfig) -> Self

Create a new engine with the given configuration.

pub fn evaluate( &mut self, record: &BlockRecord, now_secs: u64, ) -> RetentionDecision

Evaluate the retention decision for a single BlockRecord.

Rules are evaluated in order; the first matching rule wins. If no rule matches, config.default_decision is returned. Statistics are updated after every call.

pub fn evaluate_batch( &mut self, records: &[BlockRecord], now_secs: u64, ) -> Vec<(String, RetentionDecision)>

Evaluate all records in records and return (cid, decision) pairs.

pub fn blocks_to_expire<'a>( &mut self, records: &'a [BlockRecord], now_secs: u64, ) -> Vec<&'a BlockRecord>

Return references to all blocks that should be expired.

pub fn stats(&self) -> &RetentionEngineStats

Return a reference to the current statistics.

pub fn reset_stats(&mut self)

Reset all statistics counters to zero.

Trait Implementations

impl Debug for RetentionPolicyEngine

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

Formats the value using the given formatter.