Struct DueBatch 

pub struct DueBatch {
    pub rows: Vec<PushRegistration>,
    pub unserved: usize,
}

One namespace’s due registrations, with the other namespace’s backlog counted rather than silently skipped.

Fields

rows: Vec<PushRegistration>

Due registrations of the requested namespace, in the store’s stable order.

unserved: usize

Due rows of the other namespace that were visible to this query.

Counted so a deployment running only one worker can see the backlog no worker of this kind will ever serve, instead of a report shaped like a quiet plane. A lower bound: both backends’ native overrides count the whole foreign due backlog, and the paging default reports what its final window happened to scan past — never more than the truth, and exact once a read exhausts the store.

Trait Implementations

impl Clone for DueBatch

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for DueBatch

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

Formats the value using the given formatter.

impl Default for DueBatch

fn default() -> Self

Returns the “default value” for a type.