Struct OperationService 

pub struct OperationService<B: JournalBackend> { /* private fields */ }

Journal-backed owner of durable operation intent, dispatch, and raw receipts.

Implementations

impl<B: JournalBackend> OperationService<B>

pub fn new(backend: B) -> Self

Creates a service over one backend value without acquiring authority.

pub fn from_shared(backend: Arc<B>) -> Self

Creates a service over a shared backend, supporting crash/reopen tests.

pub fn resume(&mut self) -> Result<(), OperationError>

Acquires a fresh fenced journal lease after start or recovery.

pub fn state( &self, operation: &OperationId, ) -> Result<Option<DurableOperationState>, OperationError>

Reconstructs one operation solely from a verified journal snapshot.

pub fn record( &self, operation: &OperationId, ) -> Result<Option<OperationRecord>, OperationError>

Reconstructs the complete durable record from one verified snapshot.

pub fn execute( &mut self, intent: &OperationIntent, grant: &OperationGrant, attempt: &OperationAttempt, performer: &mut dyn OperationPerformer, ) -> Result<DurableOperationState, OperationError>

Persists intent and dispatch, calls the performer once, then persists its receipt.

If recovery finds a durable dispatch, this method returns that state and never calls the performer. Missing acknowledgement likewise returns the durable dispatch state; it is not converted into failure or retry authority.