Struct PendingRecord 

pub struct PendingRecord {
    pub subject: PendingSubject,
    pub reason: PendingReason,
    pub cause: Option<String>,
}

One local first unmet condition, identified by its subject (§19.1, E5).

Fields

subject: PendingSubject

The work that cannot advance.

reason: PendingReason

The first condition in its processing order.

cause: Option<String>

The text of the error behind reason: the provider, disk or database failure, naming every cause below it. coven_pending.cause keeps it beside the record, written in the same step. Only the run that met the error writes one: opening clears every cause, and a record whose last failure went back to an app call has none. It names the failure and is no part of the record’s identity: equality ignores it, and record leaves it out.

Implementations

impl PendingRecord

pub fn new(subject: PendingSubject, reason: PendingReason) -> PendingRecord

The record of subject’s first unmet condition, with no cause.

pub fn retry(&self) -> Retry

Retry according to the cause and the owner of the unfinished work.

Trait Implementations

impl Clone for PendingRecord

fn clone(&self) -> PendingRecord

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for PendingRecord

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for PendingRecord

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Display for PendingRecord

The subject and its reason, then the error behind it when the record keeps one, such as Operation { .. }: Storage { .. }: S3: Network: ….

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

Formats the value using the given formatter.

impl FromSql for PendingRecord

A record as coven’s coven_uploads and coven_pending views hold it (api.md E4), without its cause: coven_pending.cause holds that.

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

Converts SQLite value into Rust value.

impl PartialEq for PendingRecord

fn eq(&self, other: &PendingRecord) -> 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 PendingValue for PendingRecord

const BUILD: u128 = 290421909248628099607276278153671938459u128

Drawn at random each time this crate compiles. Every refusal is made here, from checks in this crate and in the crates it depends on, so a change to any of that code, or to a dependency, compiles this crate again and draws another. A version number would not do: development never moves it, so a refusal a since-fixed bug made would never be rechecked.

fn can_retry(&self, recorded_build: u128, schema_version: u32) -> bool

A refusal is a verdict on bytes that never change, judged against what never changes either: only another build can judge it differently, and each other build checks it once (§19.1).

type Subject = PendingSubject

Stable identity, ordered as the app presents it.

fn provider_access( id: OperationId, account: String, grant: bool, ) -> PendingRecord

Report one account’s unresolved intended sharing change.

fn reload(audience: Audience) -> PendingRecord

Report an audience whose selected boundary has no committed data input.

fn writes_refused(slot: Slot, cutoff: Slot, cause: WriteCutoff) -> PendingRecord

Report a batch consumed after a preceding removal or key replacement.

fn raise_wait(write: WriteId, audience: Audience, version: u32) -> PendingRecord

Report this device’s queued write held until audience is raised to version (§18.5).

fn raise_awaited(&self) -> Option<(WriteId, &Audience, u32)>

The held write, and the audience and version it waits for a raise to, if this record is such a wait: a store state that reaches it ends the record as it installs.

fn subject(&self) -> &PendingSubject

The work that cannot advance.

fn operation(&self) -> Option<OperationId>

The journal row, if this record describes an operation.

fn move_of(&self) -> Option<MoveId>

The move this record describes, if any: cancelling the move ends it.

fn pin_of(&self) -> Option<FileId>

The file whose pin coven keeps this record describes, if any: the record ends with the pin request.

fn object(&self) -> Option<(FileWork, DeviceId, ObjectId)>

The stored object this record describes, by its uploader and id, and which work on it, if any: how coven’s views join a record to the rows whose file it is.

fn slot(&self) -> Option<Slot>

Sequence slot whose progress clears this observation.

fn ends_when_covered(&self) -> bool

Whether a slot coverage including this object without applying it, as a loaded snapshot’s do, also end this observation: true for a write that waits, false for a verdict on its bytes, which loading never clears (§19.1).

fn cause(&self) -> Option<&str>

The text of the error behind this record, which _coven_pending keeps beside it in the same write: none when no error was met in this run, or when an app call received it.

fn with_cause(self, cause: Option<String>) -> PendingRecord

This record as read back, with the cause its row keeps.

impl Serialize for PendingRecord

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 Eq for PendingRecord