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

//! KIP-13 + KIP-124 + KIP-257 client quotas.

mod buckets;
mod controller_mutation;
mod lookup;
mod request;

pub use buckets::QuotaBuckets;
pub use controller_mutation::consume_controller_mutation_quota;
pub use lookup::{lookup_ip_quota, lookup_ip_quota_with_key, lookup_quota, lookup_quota_with_key};
pub use request::consume_request_quota;

mod refresh;
pub use refresh::{ImageWatcher, run};