Struct InboxBatch 

pub struct InboxBatch {
    pub references: Vec<InboxReference>,
    pub from_broker: i64,
    pub more: bool,
    pub note: Option<String>,
}

Fields

references: Vec<InboxReference>

from_broker: i64

How many of them the broker supplied. The rest were rebuilt from the bus’s own records, which are the authority.

more: bool

True when the batch filled: call again.

note: Option<String>

Present when something is worth saying about where these references came from: an unreachable broker, a missing consumer, a team whose conversations live on Postgres.

Written for you, not for an operator. It never carries backend detail — no stream names, no error codes, no credentials — and never asks you to run something only an operator can; that detail is in the server log. A note is not an error and not a reason to retry the call that produced it: the page beside it is complete either way. It never decides pagination: when it mentions paging it only repeats that more is the authority, and more alone says whether to call again.

Trait Implementations

impl Debug for InboxBatch

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

Formats the value using the given formatter.

impl JsonSchema for InboxBatch

fn schema_name() -> Cow<'static, str>

The name of the generated JSON Schema.

fn schema_id() -> Cow<'static, str>

Returns a string that uniquely identifies the schema produced by this type.

fn json_schema(generator: &mut SchemaGenerator) -> Schema

Generates a JSON Schema for this type.

fn inline_schema() -> bool

Whether JSON Schemas generated for this type should be included directly in parent schemas, rather than being re-used where possible using the $ref keyword.

impl Serialize for InboxBatch

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

where __S: Serializer,

Serialize this value into the given Serde serializer.