Struct SchemaStore 

pub struct SchemaStore { /* private fields */ }

Per-producer schema sets, fetched lazily and cached for the process.

Implementations

impl SchemaStore

pub fn new(base: impl Into<String>, timeout: Duration) -> Self

pub fn decoders_mut(&mut self) -> &mut DecoderRegistry

The decoder table (register custom kinds through this).

pub async fn schema_for( &self, session: &Session, producer: &str, type_name: &str, ) -> Option<TypeSchema>

The schema for type_name as served by producer, fetching @rpc/<producer>/describe on first miss. None = the producer does not serve describe or does not describe this type — render structurally (never an error; RFC 08 §7 is a SHOULD for self-describing encodings).

pub async fn set_for( &self, session: &Session, producer: &str, ) -> Option<Arc<SchemaSet>>

The producer’s whole served set, on the same fetch-and-cache path as schema_for (issue #51: zenctl schema <producer> dumps the inventory, and asking type-by-type would be a different question than the one describe answers).

None = the producer does not serve describe — an honest degradation, never an error.

pub fn forget(&self, producer: &str)

Forget what we learned about one producer, so the next question goes to the bus (issue #101).

The queriers are kept: they are idle routing state, and re-declaring them is exactly the cost #37 removed.

pub fn forget_all(&self)

Forget every producer — the “re-ask schemas” action a frontend offers.

Covers the case the backoff cannot: a positive entry never expires, so a producer that changes its served set mid-session is otherwise read with the schemas it had at first contact.

pub fn known(&self) -> Vec<(String, bool)>

Producers currently answered-for, and whether each served a set — what a frontend shows next to its re-ask button.

pub fn decode( &self, schema: &TypeSchema, encoding: &WireEncoding, bytes: &[u8], ) -> Result<DecodedPayload, DecodeError>

Decode bytes under a schema, if one resolves.

pub fn encode( &self, schema: &TypeSchema, value: &Value, target: &WireEncoding, ) -> Result<Vec<u8>, DecodeError>

The other direction (issue #97): a JSON value framed for the wire. The store owns the decoder table, so the write path resolves its codec exactly where the read path does — one registration, both directions.