link-common 0.5.2-rc.2

Shared Rust implementation for KalamDB link crates
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18

use crate::{models::RowData, SeqId};

/// High-level event emitted by a materialized live-query subscription.
#[derive(Debug, Clone)]
pub enum LiveRowsEvent {
    /// The current materialized row set.
    Rows {
        subscription_id: String,
        rows: Vec<RowData>,
        last_seq_id: Option<SeqId>,
    },
    /// A server-side subscription error.
    Error {
        subscription_id: String,
        code: String,
        message: String,
    },
}