Enum LastPass 

pub enum LastPass {
    Synced,
    Offline {
        failure: StorageFailure,
        error: String,
    },
    Blocked {
        slot: Slot,
        reason: PendingReason,
        error: Option<String>,
    },
    Failed {
        failure: StatusFailure,
        error: String,
    },
}

How the last pass that reached storage, or failed trying, ended (E5), as coven_sync_status.last_pass holds it. It outlives each connection: opening keeps it, and the running loop writes it as each pass ends. An error is kept as its text, which names every cause below it with secrets and URLs already cut, so a pass read after the process that ran it ended still says why.

Variants

Synced

The pass reached its observed end; other subjects may still be pending.

Offline

The request preventing the pass received no usable provider response.

Fields

failure: StorageFailure

The network failure, as the provider adapter classified it.

error: String

The failure’s text.

Blocked

This slot invokes §5.4’s stuck-device rule.

Fields

slot: Slot

The slot that cannot apply.

reason: PendingReason

Why it cannot apply.

error: Option<String>

The text of the error that blocked the slot: the cause the slot’s pending record keeps. A device that opens already blocked has none until a pass of its own meets the error.

Failed

Storage refused the whole pass, or coven’s own operation failed.

Fields

failure: StatusFailure

What failed.

error: String

The failure’s text.

Implementations

impl LastPass

pub fn failed(failure: impl Into<SyncFailure>) -> LastPass

How a pass that failed as a whole ended.

pub async fn record(&self, database: &Database) -> Result<(), DbError>

Write this as how the last pass ended when sync failed outside a pass’s end: starting, stopping, or a local failure or panic of the loop’s, in a pass or outside one; and that nothing moves, so the state shows the failure (IO failed_worker_shows). A failure fails the store’s handle with its cause (DbError::StatePersistence), so the caller stops the work that failed.

pub async fn record_halt(&self, database: &Database) -> Result<(), DbError>

Write this, a store-wide worker’s panic, as how the last pass ended, halting sync until the store reopens: nothing moves, and no pass writes over it (IO halt). A failure fails the store’s handle, as record’s does.

pub async fn record_end( &self, database: &Database, now: SystemTime, ) -> Result<(), DbError>

Write this as how the running pass ended, now by the store’s clock, and that it moves no more. A synced pass’s end becomes the last synced time, unless that is later. A failure fails the store’s handle, as record’s does.

pub fn follow(database: &Database) -> Followed<Option<LastPass>, DbError>

Follow coven_sync_status.last_pass with a live query, as an app’s SQL does: None until a pass ends on this device.

Trait Implementations

impl Clone for LastPass

fn clone(&self) -> LastPass

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for LastPass

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for LastPass

fn deserialize<__D>( __deserializer: __D, ) -> Result<LastPass, <__D as Deserializer<'de>>::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl From<PassFailure> for LastPass

fn from(failure: PassFailure) -> LastPass

Converts to this type from the input type.

impl FromSql for LastPass

Reads coven_sync_status.last_pass.

fn column_result(value: ValueRef<'_>) -> Result<LastPass, FromSqlError>

Converts SQLite value into Rust value.

impl PartialEq for LastPass

fn eq(&self, other: &LastPass) -> bool

Tests for self and other values to be equal, and is used by ==.

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

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Serialize for LastPass

fn serialize<__S>( &self, __serializer: __S, ) -> Result<<__S as Serializer>::Ok, <__S as Serializer>::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for LastPass