crabka-replicator 0.3.7

Cross-cluster geo-replication service for Crabka (MirrorMaker-2 equivalent)
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

//! The payload that travels through the connect runtime for one replicated record.

use bytes::Bytes;

/// One record from the source cluster, carried as the connect-value type `V`
/// through the [`crabka_connect`] runtime.
///
/// Because [`crabka_connect::ConnectRecord`] has no topic/partition fields,
/// all envelope metadata is bundled here alongside the raw payload.
#[derive(Debug, Clone, PartialEq, Eq)]
pub struct ReplicatedRecord {
    /// The source topic name.
    pub topic: String,
    /// The source partition index.
    pub partition: i32,
    /// The source offset (0-based).
    pub offset: i64,
    /// Record timestamp in epoch milliseconds.
    pub timestamp: i64,
    /// Record key, or `None` for a null key.
    pub key: Option<Bytes>,
    /// Record value, or `None` for a tombstone.
    pub value: Option<Bytes>,
    /// Per-record headers in declaration order.
    pub headers: Vec<(String, Option<Bytes>)>,
}