Struct DecisionLedger 

pub struct DecisionLedger<C, A> { /* private fields */ }

Bounded pending decisions plus bounded completed tombstones.

Implementations

impl<C, A> DecisionLedger<C, A>

where C: PartialEq + BoundedDecisionValue, A: PartialEq + BoundedDecisionValue,

pub fn new(config: DecisionLedgerConfig) -> Result<Self, DecisionLedgerError>

Create an empty ledger with explicit capacity bounds.

pub fn register( &mut self, decision: PendingDecision<C, A>, ) -> Result<DecisionReceipt, DecisionLedgerError>

Register immutable decision facts, accepting exact idempotent replay.

pub fn apply_feedback( &mut self, outcome: DecisionOutcome<A>, ) -> Result<FeedbackStatus, DecisionLedgerError>

Validate and apply delayed feedback transactionally.

pub fn pending(&self, id: DecisionId) -> Option<&PendingDecision<C, A>>

Return pending decision facts without updating state.

pub fn completed(&self, id: DecisionId) -> Option<&CompletedDecision<C, A>>

Return a completed tombstone without updating state.

pub fn pending_len(&self) -> usize

Number of incomplete decisions.

pub fn completed_len(&self) -> usize

Number of retained completed tombstones.

pub fn validate(&self) -> Result<(), RillError>

Validate all feature-independent structural and bounded-value invariants.

This is available even when the optional serde feature is disabled; [ValidateState] delegates to the same checks when serde persistence is enabled.

pub fn clear_expired(&mut self, now: u64) -> Vec<DecisionId>

Explicitly clear decisions whose expiry is strictly before now.

pub fn clear_completed_before(&mut self, before: u64) -> Vec<DecisionId>

Explicitly clear tombstones observed strictly before before.

pub fn validate_state_with<FC, FA>( &self, validate_context: FC, validate_action: FA, ) -> Result<(), RillError>

where FC: FnMut(&C) -> Result<(), RillError>, FA: FnMut(&A) -> Result<(), RillError>,

Validate structural invariants and caller-owned context/action state.

Trait Implementations

impl<C: Clone, A: Clone> Clone for DecisionLedger<C, A>

fn clone(&self) -> DecisionLedger<C, A>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<C: Debug, A: Debug> Debug for DecisionLedger<C, A>

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

Formats the value using the given formatter.

impl<C: PartialEq, A: PartialEq> PartialEq for DecisionLedger<C, A>

fn eq(&self, other: &DecisionLedger<C, A>) -> bool

Equality operator ==.

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

Inequality operator !=.

impl<C: PartialEq, A: PartialEq> StructuralPartialEq for DecisionLedger<C, A>