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

//! Record cache (`statestore.cache.max.bytes`): write-back LRU layered over state
//! stores. `entry` -> `named` -> `thread`. Store wrappers live in sibling modules
//! (added in later tasks).
//!
//! The cache core (`LruCacheEntry` / `NamedCache` / `ThreadCache`) is consumed by
//! the store wrappers and runtime wiring added in later record-caching tasks, so
//! several public-in-crate items are unused at this point in the slice.
#![allow(dead_code)]

pub(crate) mod entry;
pub(crate) mod named;
pub(crate) mod thread;

pub(crate) mod kv;
pub(crate) mod session;
pub(crate) mod window;