Struct SchemaNegotiator 

pub struct SchemaNegotiator { /* private fields */ }

Schema negotiator state machine

Implementations

impl SchemaNegotiator

pub fn new(local_capabilities: Capabilities) -> Self

Creates a new schema negotiator with local capabilities

pub fn v0_5() -> Self

Creates a negotiator with v0.5 capabilities

pub fn v0_4() -> Self

Creates a negotiator with v0.4 capabilities

pub fn with_fid_mappings(self, mappings: HashMap<u16, String>) -> Self

Sets FID mappings for the negotiator

pub fn initiate(&mut self) -> Result<NegotiationMessage, NegotiationError>

Initiates negotiation by sending capabilities message

pub fn handle_message( &mut self, message: NegotiationMessage, ) -> Result<NegotiationResponse, NegotiationError>

Handles an incoming negotiation message

pub fn is_ready(&self) -> bool

Returns true if negotiation is complete and ready

pub fn state(&self) -> &NegotiationState

Returns the current negotiation state

pub fn local_capabilities(&self) -> &Capabilities

Returns the local capabilities

pub fn remote_capabilities(&self) -> Option<&Capabilities>

Returns the remote capabilities if received

pub fn detect_conflicts( local_mappings: &HashMap<u16, String>, remote_mappings: &HashMap<u16, String>, ) -> Vec<NegotiationError>

Detects FID conflicts between two mapping sets

Returns a list of all conflicts found

pub fn detect_type_mismatches( expected_types: &HashMap<u16, TypeTag>, actual_types: &HashMap<u16, TypeTag>, ) -> Vec<NegotiationError>

Detects type mismatches between expected and actual types for FIDs

Returns a list of all type mismatches found

Trait Implementations

impl Clone for SchemaNegotiator

fn clone(&self) -> SchemaNegotiator

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SchemaNegotiator

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

Formats the value using the given formatter.