Struct SchemaBinding 

pub struct SchemaBinding {
    pub version: u16,
    pub connector: String,
    pub direction: SchemaDirection,
    pub origin: SchemaOrigin,
    pub logical: Schema,
    pub external: Option<Schema>,
    pub value: Option<NativeSchema>,
    pub key: Option<NativeSchema>,
    pub mapping: Vec<SchemaFieldMapping>,
    pub control_fields: Vec<String>,
}

Immutable connector binding for one catalog generation.

Fields

version: u16

Version of this encoding and mapping semantics.

connector: String

Connector type, independent of credentials and connection handles.

direction: SchemaDirection

Source or sink binding.

origin: SchemaOrigin

Origin of the logical contract.

logical: Schema

Complete logical reader or bound query-output schema.

external: Option<Schema>

Native reader/writer fields, when an external authority exists.

value: Option<NativeSchema>

Value/table/protocol contract, distinct from observed message writers.

key: Option<NativeSchema>

Independently selected key contract, when the codec uses one.

mapping: Vec<SchemaFieldMapping>

Field mapping in logical field order.

control_fields: Vec<String>

Engine changelog fields consumed by a sink and excluded from business writes.

Implementations

impl SchemaBinding

pub fn logical( connector: impl Into<String>, direction: SchemaDirection, origin: SchemaOrigin, logical: Schema, ) -> Result<Self, SchemaBindingError>

Construct a logical-only contract; no external mutation or inference occurs.

Errors

Rejects empty/duplicate fields and contracts exceeding the representation bounds.

pub fn bind_external( &mut self, external: Schema, ) -> Result<(), SchemaBindingError>

Bind fields by exact name and type. Sources may project external fields; sinks must supply every writer field and may not discard extra input fields. Casts, defaults and nullable fills require a destination-specific policy.

Errors

Rejects missing fields, differing types or unsafe directional nullability.

pub fn canonical_bytes(&self) -> Result<Vec<u8>, SchemaBindingError>

Validate structure and produce deterministic JSON without reordering fields or unions.

Errors

Rejects invalid versions, incomplete mappings, and oversized contracts.

pub fn fingerprint(&self) -> Result<String, SchemaBindingError>

SHA-256 of the versioned canonical encoding; native identity is also retained.

Errors

Returns structural or encoding errors for an invalid contract.

pub fn decode(bytes: &[u8]) -> Result<Self, SchemaBindingError>

Decode and validate a persisted contract without contacting its external authority.

Errors

Rejects malformed, unsupported, or oversized representations.

Trait Implementations

impl Clone for SchemaBinding

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SchemaBinding

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for SchemaBinding

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Eq for SchemaBinding

impl PartialEq for SchemaBinding

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

Equality operator ==.

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

Inequality operator !=.

impl Serialize for SchemaBinding

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

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for SchemaBinding