danube_core/
lib.rs

1pub mod dispatch_strategy;
2pub mod jwt;
3pub mod message;
4pub mod metadata;
5pub mod storage;
6
7pub mod proto {
8    include!("proto/danube.rs");
9
10    // Schema Registry proto module
11    pub mod danube_schema {
12        include!("proto/danube_schema.rs");
13    }
14
15    // Edge Replicator proto module — nested under `proto` (package `danube`)
16    // so that `super::StreamMessage` in the generated code resolves to
17    // the `danube.StreamMessage` proto type defined in `danube.rs`.
18    pub mod edge {
19        include!("proto/danube.edge.rs");
20    }
21}
22
23pub mod admin_proto {
24    include!("proto/danube_admin.rs");
25}
26
27pub mod raft_proto {
28    include!("proto/danube.raft.rs");
29}
30
31/// Re-export for backward compatibility.
32pub use proto::edge as edge_proto;
33
danube_core/lib.rs

danube_core/
lib.rs
