Rustdoc for every crate in
krabka-io/krabka-broker,
rendered from the main branch.
| Crate | What it is |
|---|---|
krabka-audit | Audit event model, OCSF serialization, and write pipeline for Krabka (FedRAMP 20x MLA) |
krabka-authz | Shared Kafka-ACL authorization evaluator for the Krabka broker and gateway |
krabka-backup | Captures the inputs a point-in-time restore needs -- the RLMM snapshot, the controller metadata checkpoint, and committed group offsets -- and puts the offsets back after a restore |
krabka-barrier | Administers krabka barrier groups: define a group, trigger a cut, list cuts, and verify a cut against the log |
krabka-bench-driver | Load driver and report aggregator for the Krabka vs Strimzi benchmark harness |
krabka-broker | Cluster-capable Apache Kafka-compatible krabka broker |
krabka-docgen | Renders the Krabka broker reference pages from the broker's own in-process data |
krabka-format | Formats a krabka broker log directory: Kafka's meta.properties, the bootstrap records, and the singleton VotersRecord |
krabka-guard | Administers krabka topic write freezes and break-glass proposals: freeze a scope, thaw one, and run the two-person rule |
krabka-java-regex | Java's java.util.regex semantics in Rust: Pattern.matches, replaceAll and replaceFirst as JDK 25 reads them |
krabka-kraft-core | Deterministic, sans-IO KRaft consensus core (KIP-595/996) for Krabka — wasm-friendly |
krabka-log | Byte-compatible reader/writer for Apache Kafka's on-disk log format |
krabka-log-iobench | Bench-only crate: compares the log segment I/O path against mmap, O_DIRECT and RWF_DONTCACHE variants |
krabka-logfmt | Structured-JSON (Cloud Logging-friendly) tracing log formatter shared across Krabka services |
krabka-macros | Derive macros that let one declaration in the broker stand for code it would otherwise repeat |
krabka-object-store | Unified object-store construction (typed config -> object_store handle) shared by Krabka's KIP-405 tiered storage and observability blockstore |
krabka-parse-benches | Parses Criterion benchmark output in bencher format into structured JSON summaries |
krabka-raft | Metadata KRaft quorum (KIP-595 KraftController) for Krabka |
krabka-records-legacy | Kafka v0/v1 MessageSet (legacy) codec and v2 RecordBatch bridge |
krabka-remote-storage | KIP-405 tiered-storage SPI (RemoteStorageManager / RemoteLogMetadataManager) and reference implementations for Krabka |
krabka-remote-storage-topic | Topic-backed RemoteLogMetadataManager for Krabka tiered storage |
krabka-restore | Offline point-in-time restore: rebuilds a bootable krabka log directory from a KIP-405 tiered-storage archive |
krabka-telemetry | Generic OTLP distributed-tracing pipeline for Krabka services |
krabka-throttle | Shared token-bucket throttling primitives for Krabka |
krabka-verified | Formally verified pure kernels (Creusot) shared by Krabka crates |