Enum SqlSourcePosition 

pub enum SqlSourcePosition {
    Custom {
        connector: Arc<str>,
        position: Arc<str>,
    },
}

Type-erased source position carried by SQL sink pipelines.

Connector adapters keep their precise position types at the edge and convert them into this enum when a query needs commit-after-sink-confirmation.

Variants

Custom

Opaque source position for user-defined connector adapters.

Fields

connector: Arc<str>

Connector family or instance name.

position: Arc<str>

Connector-specific position text.

Implementations

impl SqlSourcePosition

pub fn custom( connector: impl Into<Arc<str>>, position: impl Into<Arc<str>>, ) -> Self

Creates an opaque connector-specific source position.

Trait Implementations

impl Clone for SqlSourcePosition

fn clone(&self) -> SqlSourcePosition

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SqlSourcePosition

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

Formats the value using the given formatter.

impl Eq for SqlSourcePosition

impl PartialEq for SqlSourcePosition

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for SqlSourcePosition