Enum SubscriptionCatchup 

pub enum SubscriptionCatchup {
    Unknown {
        id: String,
    },
    Known {
        id: String,
        table: String,
        status: String,
        cursor: i64,
        has_resume_token: bool,
        bootstrap_complete: bool,
        known_pending_pages: bool,
        effective_scopes: Option<Value>,
        reason_code: Option<String>,
    },
}

§7.5: the catch-up state of one subscription, read from the persisted subscription record inside the snapshot transaction (never the mutable owner cache). Unknown means the client does not currently hold the subscription (it was never registered, or it was forgotten or removed); it carries no fabricated table or cursor. A known state carries the persisted status (active, revoked, or failed), the cursor, and whether a resume token is held. A reset subscription stays active with cursor < 0; it is not a fourth status.

Variants

Unknown

The client does not currently hold this subscription id.

Fields

id: String

Known

Fields

id: String

table: String

status: String

The persisted status name: active, revoked, or failed.

cursor: i64

has_resume_token: bool

bootstrap_complete: bool

True only for an active subscription with cursor >= 0 and no resume token. Never true for a failed, revoked, or reset subscription.

known_pending_pages: bool

True only for an active subscription while a resume token remains or cursor < 0. A reset subscription stays active with cursor < 0, so it reads true while it bootstraps; a failed or revoked subscription reads false.

effective_scopes: Option<Value>

reason_code: Option<String>

Trait Implementations

impl Clone for SubscriptionCatchup

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 SubscriptionCatchup

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

Formats the value using the given formatter.

impl Serialize for SubscriptionCatchup

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

where __S: Serializer,

Serialize this value into the given Serde serializer.