danube-connect-core 0.5.0

Core SDK for building Danube connectors
Documentation 
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

//! Runtime for managing connector lifecycle.
//!
//! This module provides runtime implementations for both sink and source connectors:
//! - `SinkRuntime`: Handles Danube → External System (consuming from Danube)
//! - `SourceRuntime`: Handles External System → Danube (producing to Danube)
//!
//! The runtimes handle:
//! - Connector initialization
//! - Danube client setup and connection management
//! - Message processing loops
//! - Retry logic
//! - Health monitoring
//! - Graceful shutdown

mod context;
mod sink_runtime;
mod source_runtime;

// Re-export internal types for use within the crate
pub(crate) use context::ConnectorContext;

// Re-export public API types
/// Runtime for sink connectors that consume from Danube and write to external systems.
pub use sink_runtime::SinkRuntime;
/// Runtime for source connectors that read from external systems and publish to Danube.
pub use source_runtime::SourceRuntime;