Struct IncomingTopicStatus 

pub struct IncomingTopicStatus {
    pub topic: Topic,
    pub scope_generation: u64,
    pub registration: IncomingRegistration,
    pub target: Option<Cursor>,
    pub received: Cursor,
    pub processed: Cursor,
    pub unresolved_welcomes: u64,
    pub processing: IncomingProcessing,
    pub blocked: Option<String>,
    pub error: Option<Arc<IncomingError>>,
}

Per-topic proof of durable receipt and processing through one fixed head.

Fields

topic: Topic

Topic whose progress is reported.

scope_generation: u64

Scope revision that owns this target; old revisions cannot complete a new scope.

registration: IncomingRegistration

Registration is separate from both transport health and processing.

target: Option<Cursor>

Fixed head H; None means no target has been established yet.

received: Cursor

Durable received prefix F, including retained pending work.

processed: Cursor

Durable processed prefix P, including terminal rejections.

unresolved_welcomes: u64

Unresolved Welcomes at or below H; later successes cannot hide them.

processing: IncomingProcessing

Completion predicate for this topic, not an application acknowledgement.

blocked: Option<String>

Stable reason code when retained work cannot currently proceed.

error: Option<Arc<IncomingError>>

Latest error for this topic; sibling topics can still make progress.

Trait Implementations

impl Clone for IncomingTopicStatus

fn clone(&self) -> IncomingTopicStatus

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for IncomingTopicStatus

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

Formats the value using the given formatter.