Module iq 

Byte-level read surface for Interactive Queries.

The supervisor calls these methods through &dyn StateStore::as_iq() to serve KafkaStreams::*_store queries, and it never learns K or V. The typed view owns the serialization and deserialization. All reads take &self, and only key and value bytes cross this trait.

Enums

Iq2Failure

Why a store could not run an IQv2 query. The runtime maps these variants into the public FailureReason, together with its own conditions: rebalancing, not-up-to-bound, and not-active.

Iq2Query

A typed IQv2 query lowered to the store boundary.

StoreKind

Which kind of store a query targets. Public so it can appear in IqError.