krabka_replicator/lib.rs
1//! `krabka-replicator`: cross-cluster geo-replication for Krabka.
2// `#[tracing::instrument]` wraps each async fn's future in an extra layer;
3// combined with the deeply-nested consumer/producer futures this pushes the
4// type-layout query past the default depth limit, so raise it.
5#![recursion_limit = "256"]
6
7pub mod admin_util;
8pub mod checkpoint_store;
9pub mod config;
10pub mod error;
11pub mod ids;
12pub mod mm2;
13pub mod naming;
14pub mod offset_sync_store;
15pub mod record;
16pub mod residency;
17pub mod selector;
18pub mod sink;
19pub mod source;
20pub mod supervisor;
21pub mod tasks;
22pub mod worker;
23
24pub use error::{ReplicatorError, Result};
25
26#[cfg(test)]
27mod test_util;