danube_client/
lib.rs

1//! Danube-Client
2//!
3//! Danube-Client -- the Danube stream service client
4
5mod client;
6pub use client::{DanubeClient, DanubeClientBuilder};
7
8mod auth_service;
9
10pub mod errors;
11
12mod producer;
13pub use producer::{Producer, ProducerBuilder, ProducerOptions};
14
15mod topic_producer;
16
17mod consumer;
18pub use consumer::{Consumer, ConsumerBuilder, ConsumerOptions, SubType};
19
20mod topic_consumer;
21
22mod message_router;
23
24// New Schema Registry Client
25mod schema_registry_client;
26pub use schema_registry_client::{SchemaRegistrationBuilder, SchemaRegistryClient};
27
28mod schema_types;
29pub use schema_types::{CompatibilityMode, SchemaInfo, SchemaType};
30
31// Re-export proto types for schema reference (advanced use)
32pub use danube_core::proto::SchemaReference;
33pub use danube_core::proto::schema_reference::VersionRef;
34
35mod lookup_service;
36
37mod connection_manager;
38
39mod health_check;
40
41mod retry_manager;