Enum SourcePosition 

pub enum SourcePosition {
    Kafka(KafkaPosition),
    PostgresCdc(PostgresCdcPosition),
    MysqlCdc(MysqlCdcPosition),
    File(FilePosition),
    Generic(GenericPosition),
}

Strongly typed source position.

Each variant captures the native offset format for a connector type, enabling type-safe validation and recovery planning.

Variants

Kafka(KafkaPosition)

Kafka consumer group offsets.

PostgresCdc(PostgresCdcPosition)

PostgreSQL CDC replication slot position.

MysqlCdc(MysqlCdcPosition)

MySQL CDC binlog/GTID position.

File(FilePosition)

File source byte offset.

Generic(GenericPosition)

Generic connector offsets.

Implementations

impl SourcePosition

pub fn to_connector_checkpoint(&self, epoch: u64) -> ConnectorCheckpoint

Convert to a ConnectorCheckpoint for storage.

pub fn from_connector_checkpoint( cp: &ConnectorCheckpoint, type_hint: Option<&str>, ) -> Option<Self>

Try to reconstruct a typed position from a ConnectorCheckpoint.

Uses the connector_type metadata key to determine which variant to build. Returns None if the type is unknown or the offsets are incomplete.

pub fn to_offset_entry(&self, epoch: u64) -> SourceOffsetEntry

Convert to a SourceOffsetEntry for the V2 manifest format.

pub fn from_offset_entry(entry: &SourceOffsetEntry) -> Option<Self>

Reconstruct a typed position from a SourceOffsetEntry.

Returns None if the entry’s source type is unrecognized or the offsets are incomplete.

Trait Implementations

impl Clone for SourcePosition

fn clone(&self) -> SourcePosition

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SourcePosition

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for SourcePosition

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl PartialEq for SourcePosition

fn eq(&self, other: &SourcePosition) -> 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 SourcePosition

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 SourcePosition

impl StructuralPartialEq for SourcePosition