Struct SubscriptionInfo 

pub struct SubscriptionInfo {
    pub id: String,
    pub query: String,
    pub last_seq_id: Option<SeqId>,
    pub last_event_time_ms: Option<u64>,
    pub created_at_ms: u64,
    pub closed: bool,
}

Read-only snapshot of an active subscription’s metadata.

Returned by [KalamLinkClient::subscriptions()] and the WASM getSubscriptions() method.

Fields

id: String

Subscription ID assigned when subscribing.

query: String

The SQL query this subscription is tracking.

last_seq_id: Option<SeqId>

Last received sequence ID (used for resume-from on reconnect).

last_event_time_ms: Option<u64>

Timestamp (millis since Unix epoch) of the last received event, or None if no events have been received yet.

created_at_ms: u64

Timestamp (millis since Unix epoch) when the subscription was created.

closed: bool

Whether the subscription has been closed.

Trait Implementations

impl Clone for SubscriptionInfo

fn clone(&self) -> SubscriptionInfo

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SubscriptionInfo

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for SubscriptionInfo

fn deserialize<__D>( __deserializer: __D, ) -> Result<SubscriptionInfo, <__D as Deserializer<'de>>::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for SubscriptionInfo

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

where __S: Serializer,

Serialize this value into the given Serde serializer.