Struct Journal 

pub struct Journal<'write> { /* private fields */ }

The journal inside one write, for sync’s steps.

Implementations

impl<'write> Journal<'write>

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

The operation’s journal row, as this write sees it; None once it has finished, or if it never existed.

pub fn operations(&self, kind: &str) -> Result<Vec<OperationRecord>, DbError>

The journal’s rows of kind, oldest first, as this write sees them.

pub fn advance_operation(&self, update: &OperationUpdate) -> Result<(), DbError>

Advance an operation one step past the row it read; its pending record and retry wait end with the step it left. A row that has moved on since fails with OperationChanged.

pub fn store_state(&self) -> Result<StoreState, DbError>

Membership and audience state after the applied slots, as this write sees it.

pub fn applied_slot(&self) -> Result<u64, DbError>

The last slot whose effects this device has applied.

pub fn start_operation( &self, operation: &NewOperation, ) -> Result<OperationId, DbError>

Journal an operation before its first step, which sync runs and ends on its own; coven_operations doesn’t list it.

pub fn start_app_operation( &self, operation: &NewOperation, kind: &str, ) -> Result<OperationId, DbError>

Journal an operation the app’s write asks for, of kind as sync names it, before its first step. It is listed in coven_operations from this write’s commit until the app acknowledges its outcome.

pub fn operation_pending<P: PendingValue>( &self, id: OperationId, ) -> Result<Option<P>, DbError>

The pending record that names the operation, if any.

pub fn pending_can_retry<P: PendingValue>( &self, subject: &P::Subject, ) -> Result<bool, DbError>

Whether automatic work can retry the subject with the coven and schema versions installed now.

pub fn clear_pending<S: Serialize>(&self, subject: &S) -> Result<(), DbError>

Clear the subject’s pending record.

pub fn clear_retry(&self, subject: RetrySubject) -> Result<(), DbError>

Clear the subject’s retry wait.