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 serde::{Deserialize, Serialize};

use super::consume_message::ConsumeMessage;

/// Result of consuming from a topic.
///
/// Contains the batch of messages and metadata for pagination.
#[derive(Debug, Clone, Serialize, Deserialize)]
pub struct ConsumeResponse {
    /// Consumed messages in this batch
    pub messages: Vec<ConsumeMessage>,

    /// Next offset to consume from (for subsequent polls)
    pub next_offset: u64,

    /// Whether more messages are available beyond this batch
    pub has_more: bool,
}