Struct InputDecoder 

pub struct InputDecoder { /* private fields */ }

Per-input receive state for the schema-once zenoh path: one persistent StreamDecoder primed from the schema published on the output’s @schema subtopic (or in-band, from the schema block of a full self-describing stream on the data topic), then reused to decode the schema-less batch messages that flow on the data topic.

Implementations

impl InputDecoder

pub fn new() -> Self

Create an unprimed decoder. It decodes nothing until a schema is installed via set_schema (delivered from the output’s @schema subtopic).

pub fn reset(&mut self)

Forget all state — the primed decoder AND the retained schemas. The next schema message must re-establish priming. Used on producer restart and for lock-poison recovery.

pub fn knows_schema(&self, hash: u64) -> bool

Whether a schema with this hash is already available — live or retained. The in-band priming path skips the schema-block copy and the eager re-prime for known schemas; decode_batch re-primes lazily from the retained set when a batch actually needs one, so eagerly re-priming a retained schema would only churn the live decoder (e.g. a large full-stream message of schema B clobbering the live prime of schema A between A’s schema-less batches).

pub fn set_schema(&mut self, hash: u64, schema: ArrowBuffer) -> Result<()>

Install the schema for hash from a framed IPC schema message (the payload published on the @schema subtopic, or the schema block of a full stream received in-band): prime a fresh decoder with it and retain the bytes for later local re-priming. A no-op when the live decoder is already primed with hash.

pub fn decode_batch( &mut self, buffer: ArrowBuffer, hash: u64, ) -> Result<Option<ArrayData>>

Decode a schema-less batch message against the decoder primed for hash.

If the live decoder is not primed for hash but a matching schema was previously installed (e.g. after a soft reset), it re-primes from the retained bytes first. Returns Ok(None) when no schema for hash is known yet — the caller drops the message, which is fine on the lossy CongestionControl::Drop data plane (the @schema history query, the next schema publish, or the producer’s periodic full-stream refresh — which primes in-band — will prime it).

Trait Implementations

impl Default for InputDecoder

fn default() -> Self

Returns the “default value” for a type.