Struct ConnectorCheckpoint 

pub struct ConnectorCheckpoint {
    pub offsets: HashMap<String, String>,
    pub epoch: u64,
    pub metadata: HashMap<String, String>,
}

Connector-agnostic offset container.

Uses string key-value pairs to support all connector types:

• Kafka: {"partition-0": "1234", "partition-1": "5678"}
• PostgreSQL CDC: {"lsn": "0/1234ABCD"}
• MySQL CDC: {"gtid_set": "uuid:1-5", "binlog_file": "mysql-bin.000003"}
• Delta Lake: {"version": "42"}

Fields

offsets: HashMap<String, String>

Connector-specific offset data.

epoch: u64

Epoch this checkpoint belongs to.

metadata: HashMap<String, String>

Optional metadata (connector type, topic name, etc.).

Implementations

impl ConnectorCheckpoint

pub fn new(epoch: u64) -> Self

Creates a new connector checkpoint with the given epoch.

pub fn with_offsets(epoch: u64, offsets: HashMap<String, String>) -> Self

Creates a connector checkpoint with pre-populated offsets.

Trait Implementations

impl Clone for ConnectorCheckpoint

fn clone(&self) -> ConnectorCheckpoint

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ConnectorCheckpoint

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for ConnectorCheckpoint

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl PartialEq for ConnectorCheckpoint

fn eq(&self, other: &ConnectorCheckpoint) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Serialize for ConnectorCheckpoint

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

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl Eq for ConnectorCheckpoint

impl StructuralPartialEq for ConnectorCheckpoint