Struct Finalizer 

pub struct Finalizer { /* private fields */ }

Shared asynchronous finalization service.

Implementations

impl Finalizer

pub fn metrics(&self) -> &Arc<Registry>

Access the shared metrics registry so background paths (stream abort, worker-side supervision) can bump counters without plumbing the registry through every struct field.

pub fn new( signer: Arc<dyn Signer>, spool_dir: PathBuf, metrics: Arc<Registry>, ) -> Self

Create a finalizer writing unsigned artifacts beneath spool_dir.

pub fn with_bridge( signer: Arc<dyn Signer>, spool_dir: PathBuf, metrics: Arc<Registry>, bridge: Arc<dyn EventBus>, ) -> Self

Create a finalizer that also emits receipt events to the Bridge.

pub fn with_state_store(self, store: Arc<dyn StateStore>) -> Self

Attach the quota/budget state store whose per-session counters are cleared when a session is sealed.

pub async fn close_session( &self, session: Arc<Session>, stop_reason: StopReason, ) -> Result<FinalizeOutcome, FinalizeError>

Close exactly once. Receipt signing and ATIF serialization never run on the request hot path.

pub async fn promote( &self, session: Arc<Session>, ) -> Result<Receipt, FinalizeError>

Promote a persisted unsigned trajectory into a retroactive Receipt.

pub async fn recover_spooled_sessions( &self, sessions: &SessionRegistry, breaker: &BreakerConfig, ) -> Result<usize, FinalizeError>

Recover interrupted sessions from the spool: quarantine sessions with incomplete effects, replay lifecycle outboxes, recover signed journal sessions, consolidate unsigned step journals, then scan strict ATIF artifacts for closed unsigned sessions. Returns the total count of recovered sessions (unsigned + signed).

pub async fn retry_marked_promotions( &self, sessions: &SessionRegistry, ) -> Result<usize, FinalizeError>

Retry every durable promotion marker whose session can be recovered.

Trait Implementations

impl Clone for Finalizer

fn clone(&self) -> Finalizer

Returns a duplicate of the value.

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

Performs copy-assignment from source.