Struct SchemaRecvTracker 

pub struct SchemaRecvTracker { /* private fields */ }

Tracks schemas received from the remote peer on the current connection.

Uses interior mutability (Mutex) so it can be shared via Arc between the session recv loop and in-flight handler tasks. Created fresh on each connection — NOT reused across reconnections.

Implementations

impl SchemaRecvTracker

pub fn new() -> Self

pub fn record_received( &self, method_id: MethodId, direction: BindingDirection, payload: SchemaPayload, ) -> Result<(), DuplicateSchemaError>

Record a parsed schema message from the remote peer.

Returns Err if a TypeSchemaId was already received — this is a protocol error (the send tracker didn’t reset on reconnection).

pub fn get_remote_args_root(&self, method_id: MethodId) -> Option<TypeRef>

Look up the remote’s root TypeRef for a method’s args.

pub fn get_remote_response_root(&self, method_id: MethodId) -> Option<TypeRef>

Look up the remote’s root TypeRef for a method’s response.

pub fn get_received(&self, type_id: &SchemaHash) -> Option<Schema>

Look up a received schema by type ID.

pub fn received_registry(&self) -> SchemaRegistry

Get a snapshot of the received schema registry for building translation plans.

Trait Implementations

impl Debug for SchemaRecvTracker

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

Formats the value using the given formatter.

impl Default for SchemaRecvTracker

fn default() -> Self

Returns the “default value” for a type.

impl SchemaSource for SchemaRecvTracker

fn get_schema(&self, id: SchemaHash) -> Option<Schema>