Trait PendingValue 

pub trait PendingValue:
    Serialize
    + DeserializeOwned
    + Send
    + 'static {
    type Subject: Serialize + Ord;

    const BUILD: u128;

    // Required methods
    fn writes_refused(slot: Slot, cutoff: Slot, cause: WriteCutoff) -> Self;
    fn reload(audience: Audience) -> Self;
    fn raise_wait(write: WriteId, audience: Audience, version: u32) -> Self;
    fn raise_awaited(&self) -> Option<(WriteId, &Audience, u32)>;
    fn provider_access(
        operation: OperationId,
        account: String,
        grant: bool,
    ) -> Self;
    fn subject(&self) -> &Self::Subject;
    fn operation(&self) -> Option<OperationId>;
    fn object(&self) -> Option<(FileWork, DeviceId, ObjectId)>;
    fn move_of(&self) -> Option<MoveId>;
    fn pin_of(&self) -> Option<FileId>;
    fn slot(&self) -> Option<Slot>;
    fn ends_when_covered(&self) -> bool;
    fn can_retry(&self, recorded_build: u128, schema_version: u32) -> bool;
    fn cause(&self) -> Option<&str>;
    fn with_cause(self, cause: Option<String>) -> Self;
}

Sync supplies its complete typed record; the database owns its atomic lifetime. The associated subject is the stable key, independent of the reason.

Required Associated Constants

const BUILD: u128

The build of coven that judges these records, which every record saved names: one draws its own at each compilation, so a change to the code that judges gives another (§19.1).

Required Associated Types

type Subject: Serialize + Ord

Stable identity, ordered as the app presents it.

Required Methods

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

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

fn reload(audience: Audience) -> Self

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

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

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 provider_access(operation: OperationId, account: String, grant: bool) -> Self

Report one account’s unresolved intended sharing change.

fn subject(&self) -> &Self::Subject

The work that cannot advance.

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

The journal row, if this record describes an operation.

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 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 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 can_retry(&self, recorded_build: u128, schema_version: u32) -> bool

Whether automatic work can retry, given the build that recorded this record and the app’s installed schema version.

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>) -> Self

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

Dyn Compatibility

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety", so this trait is not object safe.

Implementors