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
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48

use kalamdb_commons::UserId;
use serde::{Deserialize, Serialize};

use super::TopicOp;
use crate::models::RowData;

/// A single consumed message from a topic.
///
/// Contains the message payload (decoded from base64), metadata about the
/// source operation, and positioning information for acknowledgment.
#[derive(Debug, Clone, Serialize, Deserialize)]
pub struct ConsumeMessage {
    /// Optional message key from the topic envelope.
    #[serde(default, skip_serializing_if = "Option::is_none", alias = "message_id")]
    pub key: Option<String>,

    /// Operation type from the topic envelope (`Insert`, `Update`, or `Delete`).
    #[serde(skip_serializing_if = "Option::is_none")]
    pub op: Option<TopicOp>,

    /// Message timestamp in milliseconds since epoch
    #[serde(skip_serializing_if = "Option::is_none")]
    pub timestamp_ms: Option<u64>,

    /// Message offset in the partition (used for acknowledgment)
    pub offset: u64,

    /// Partition this message belongs to
    pub partition_id: u32,

    /// Topic this message belongs to
    pub topic: String,

    /// Consumer group ID
    pub group_id: String,

    /// Canonical user identifier of the user who produced this message/event.
    /// This is required for consumer-facing change processing.
    #[serde(alias = "username", alias = "user_id")]
    pub user: UserId,

    /// Decoded payload from the HTTP API's base64 `payload` field.
    ///
    /// For `WITH (payload = 'full')` routes this is usually the changed row JSON,
    /// plus `_table` metadata identifying the source table.
    #[serde(alias = "value")]
    pub payload: RowData,
}