krabka_client_streams/runtime/iqv2/mod.rs
1//! Interactive Queries v2 (KIP-796 / 960 / 968): the `StateQueryRequest` →
2//! `KafkaStreams::query` → `StateQueryResult` envelope and its query objects.
3//!
4//! This module uses a channel of its own, separate from the v1
5//! `ReadOnly*Store` views in `runtime::iq_view`. It does not change v1.
6
7#[cfg(not(target_family = "wasm"))]
8pub(crate) mod dispatch;
9pub mod query;
10pub mod request;
11pub mod result;
12
13pub use query::{
14 KeyQuery, MultiVersionedKeyQuery, Query, RangeQuery, VersionedKeyQuery, WindowKeyQuery,
15 WindowRangeQuery,
16};
17pub use request::{Position, PositionBound, StateQuery, StateQueryRequest};
18pub use result::{FailureReason, QueryResult, StateQueryResult};