crabka-broker 0.3.6

Single-node Apache Kafka-compatible broker (MVP)
Documentation 
1
2
3
4
5
6
7
8
9

//! KIP-932 share-partition leader: the in-memory acquisition state machine.
//!
//! Distinct from `share_coordinator::state::SharePartitionState` (the
//! *persisted* type). [`state::AcquisitionState`] is the live, per-partition
//! offset-range state machine the share-partition leader drives during
//! `ShareFetch`/`ShareAcknowledge`.
pub mod manager;
pub mod session;
pub mod state;