Module iqv2 

Interactive Queries v2 (KIP-796 / 960 / 968): the StateQueryRequest → KafkaStreams::query → StateQueryResult envelope and its query objects.

This module uses a channel of its own, separate from the v1 ReadOnly*Store views in runtime::iq_view. It does not change v1.

Re-exports

pub use query::KeyQuery;

pub use query::MultiVersionedKeyQuery;

pub use query::Query;

pub use query::RangeQuery;

pub use query::VersionedKeyQuery;

pub use query::WindowKeyQuery;

pub use query::WindowRangeQuery;

pub use request::Position;

pub use request::PositionBound;

pub use request::StateQuery;

pub use request::StateQueryRequest;

pub use result::FailureReason;

pub use result::QueryResult;

pub use result::StateQueryResult;

Modules

query

IQv2 query objects. Each builder lowers to a store::iq::Iq2Query with no serde, and the store supplies the actual serdes.

request

IQv2 request envelope: Position/PositionBound (KIP-796 bounded staleness), partition selection, and the finalized StateQuery<Q> that KafkaStreams::query consumes.

result

IQv2 results. Each partition gives a QueryResult<R>, and the code aggregates them into a StateQueryResult<R>.