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

//! Message transformation utilities.
//!
//! This module provides helper types and methods for transforming messages between
//! Danube's format and connector-specific formats.

mod context;
mod sink_record;
mod source_record;

// Re-export message types
pub use context::{RecordContext, RoutingContext};
pub use sink_record::{DanubeMetadata, SinkRecord};
pub use source_record::SourceRecord;