1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33

//! Danube-Client
//!
//! Danube-Client -- the Danube stream service client

pub mod proto {
    include!("proto/danube.rs");
}

mod client;
pub use client::DanubeClient;

pub mod errors;

mod producer;
pub use producer::{Producer, ProducerBuilder, ProducerOptions};

mod consumer;
pub use consumer::{Consumer, ConsumerBuilder, ConsumerOptions, SubType};

mod schema;
pub use schema::{Schema, SchemaType};

mod schema_service;

mod message;

mod lookup_service;

mod connection_manager;

mod rpc_connection;

mod health_check;