crabka-client-streams 0.3.6

KIP-1071 Kafka Streams rebalance-protocol client for Apache Kafka in Rust
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16

//! Interactive Queries v2 (KIP-796 / 960 / 968): the `StateQueryRequest` →
//! `KafkaStreams::query` → `StateQueryResult` envelope and its query objects.
//! Coexists with the v1 `ReadOnly*Store` views (see `runtime::iq_view`) on a
//! separate channel; v1 is untouched.

pub(crate) mod dispatch;
pub mod query;
pub mod request;
pub mod result;

pub use query::{
    KeyQuery, MultiVersionedKeyQuery, Query, RangeQuery, VersionedKeyQuery, WindowKeyQuery,
    WindowRangeQuery,
};
pub use request::{Position, PositionBound, StateQuery, StateQueryRequest};
pub use result::{FailureReason, QueryResult, StateQueryResult};