Struct SchemaEvolutionFrame 

pub struct SchemaEvolutionFrame {
    pub session_id: String,
    pub old_version: SchemaVersion,
    pub new_version: SchemaVersion,
    pub schema_ipc: Vec<u8>,
}

Wire frame that signals a schema change mid-stream in a TensorSwap session.

When a sender wants to start emitting data using a different Arrow schema it first serialises a SchemaEvolutionFrame and transmits it to the receiver. The receiver must acknowledge the new schema before the sender continues with Arrow IPC batches encoded against new_version.

Fields

session_id: String

Identifier of the TensorSwap session this evolution applies to.

old_version: SchemaVersion

The schema version that was active before the change.

new_version: SchemaVersion

The schema version that will be used after the change.

schema_ipc: Vec<u8>

Serialised Arrow IPC Schema message bytes for new_version.

Encoded using arrow::ipc::writer::schema_to_bytes so that the receiver can reconstruct the full Schema without registry access.

Implementations

impl SchemaEvolutionFrame

pub fn new( session_id: impl Into<String>, old_version: SchemaVersion, new_version: SchemaVersion, new_schema: &Schema, ) -> Self

Construct a SchemaEvolutionFrame, serialising new_schema into Arrow IPC format automatically.

pub fn to_bytes(&self) -> Result<Vec<u8>, SchemaError>

Serialise this frame to JSON bytes suitable for transmission.

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

Deserialise a SchemaEvolutionFrame from JSON bytes.

pub fn decode_schema(&self) -> Result<Arc<Schema>, SchemaError>

Recover the Arrow Schema embedded in schema_ipc.

Trait Implementations

impl Clone for SchemaEvolutionFrame

fn clone(&self) -> SchemaEvolutionFrame

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SchemaEvolutionFrame

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for SchemaEvolutionFrame

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for SchemaEvolutionFrame

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

where __S: Serializer,

Serialize this value into the given Serde serializer.