reifydb_cdc/
lib.rs

1// Copyright (c) reifydb.com 2025
2// This file is licensed under the AGPL-3.0-or-later, see license.md file
3
4#![cfg_attr(not(debug_assertions), deny(warnings))]
5
6use reifydb_core::interface::version::{ComponentType, HasVersion, SystemVersion};
7
8mod checkpoint;
9mod consumer;
10mod poll;
11mod watermark;
12
13pub use checkpoint::CdcCheckpoint;
14pub use consumer::{CdcConsume, CdcConsumer};
15pub use poll::{PollConsumer, PollConsumerConfig};
16pub use watermark::compute_watermark;
17
18pub struct CdcVersion;
19
20impl HasVersion for CdcVersion {
21	fn version(&self) -> SystemVersion {
22		SystemVersion {
23			name: "cdc".to_string(),
24			version: env!("CARGO_PKG_VERSION").to_string(),
25			description: "Change Data Capture module".to_string(),
26			r#type: ComponentType::Module,
27		}
28	}
29}