Struct DeviceJoinJournalDatabase 

pub struct DeviceJoinJournalDatabase { /* private fields */ }

Durable role journal. Each row stores a closed progress value; SQLite’s compare-and-swap update rejects stale or skipped transitions.

Implementations

impl DeviceJoinJournalDatabase

pub fn open( path: impl AsRef<Path>, ) -> Result<DeviceJoinJournalDatabase, DeviceJoinError>

pub fn begin( &self, record: DeviceJoinJournalRecord, ) -> Result<DeviceJoinJournalRecord, DeviceJoinError>

pub fn load( &self, attempt_id: DeviceJoinAttemptId, role: DeviceJoinRole, ) -> Result<Option<DeviceJoinJournalRecord>, DeviceJoinError>

pub fn advance( &self, previous: &DeviceJoinJournalRecord, next: DeviceJoinJournalRecord, ) -> Result<(), DeviceJoinError>

pub fn stage_pending_transfer( &self, record: &DeviceJoinJournalRecord, ) -> Result<ObjectHash, DeviceJoinError>

pub fn transfer_pending_to( &self, destination: &DeviceJoinJournalDatabase, attempt_id: DeviceJoinAttemptId, ) -> Result<DeviceJoinJournalRecord, DeviceJoinError>

Move one pending joiner payload into the installed Store journal in one SQLite transaction spanning the source and destination databases.

Trait Implementations

impl Clone for DeviceJoinJournalDatabase

fn clone(&self) -> DeviceJoinJournalDatabase

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for DeviceJoinJournalDatabase

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

Formats the value using the given formatter.