crabka-broker 0.3.6

Single-node Apache Kafka-compatible broker (MVP)
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16

//! KIP-932 share-state persister RPC handlers (api keys 83–87). Each handler
//! decodes the typed request, gates every `(topic, partition)` on
//! [`crate::share_coordinator::coordinator::ShareCoordinator::is_leader`] for
//! its state partition (returning per-partition `NOT_COORDINATOR` otherwise),
//! delegates to the matching coordinator method, and maps the result to a
//! per-partition `error_code`.
//!
//! These are inter-broker RPCs and carry no per-connection ACL context, so the
//! plain 4-arg [`crate::handlers::HandlerFn`] form fits (see
//! [`crate::txn::handlers::write_txn_markers`]).

pub(crate) mod delete;
pub(crate) mod initialize;
pub(crate) mod read;
pub(crate) mod read_summary;
pub(crate) mod write;