Struct QueuedUpload 

pub struct QueuedUpload {
    pub blob: RowBlobRef,
    pub root_table: String,
    pub root_id: String,
    pub root_label: String,
    pub retain_pinned: bool,
    pub phase: QueuedUploadPhase,
    pub provider_bytes_total: Option<u64>,
    pub attempt_count: u64,
    pub last_failure: Option<OutboxFailure>,
    pub created_at: String,
    pub last_attempt_at: Option<String>,
}

One upload the durable cloud queue is holding, as a host renders it.

This is a projection of the queue row, not the drain’s working entry: it carries what a person needs to see — which blob, which row it belongs to, whether it is retried and why — and none of the transfer bookkeeping the drain needs. attempt_count is 0 and last_error is None until a transfer has actually been tried and failed, so a freshly queued upload is distinguishable from a retrying one.

Fields

blob: RowBlobRef

The exact blob-bearing row version held by the durable queue. This is the same identity upload lifecycle callbacks report.

root_table: String

The gated root whose make-remote enqueued this upload. Every upload for one root shares this pair, and the root is what a host groups by.

root_id: String

root_label: String

What the host called this root when it queued the work, snapshotted here so the queue can name its own entries. The root row is exactly what a cancelled or deleted root no longer has, and an entry that cannot say what it is is an entry a host cannot render or a person cancel.

retain_pinned: bool

Whether the transition asked for the plaintext to stay cached locally once the upload lands.

phase: QueuedUploadPhase

The durable handoff this exact upload has reached. In-memory transfer activity refines this into Preparing or Uploading; after a restart this is the authoritative lower bound the host renders immediately.

provider_bytes_total: Option<u64>

Exact bytes the cloud provider receives once preparation has produced the stored object. Pending preparation has no provider denominator yet.

attempt_count: u64

Failed transfer attempts so far; 0 for an upload never yet tried.

last_failure: Option<OutboxFailure>

Why the last attempt failed, if one has.

created_at: String

When the upload was enqueued.

last_attempt_at: Option<String>

When it was last attempted, if it has been.

Trait Implementations

impl Clone for QueuedUpload

fn clone(&self) -> QueuedUpload

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for QueuedUpload

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

Formats the value using the given formatter.

impl PartialEq for QueuedUpload

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

impl StructuralPartialEq for QueuedUpload