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
4use reifydb_core::interface::version::{ComponentType, HasVersion, SystemVersion};
5
6mod checkpoint;
7mod consumer;
8mod poll;
9mod watermark;
10
11pub use checkpoint::CdcCheckpoint;
12pub use consumer::{CdcConsume, CdcConsumer};
13pub use poll::{PollConsumer, PollConsumerConfig};
14pub use watermark::compute_watermark;
15
16pub struct CdcVersion;
17
18impl HasVersion for CdcVersion {
19	fn version(&self) -> SystemVersion {
20		SystemVersion {
21			name: "cdc".to_string(),
22			version: env!("CARGO_PKG_VERSION").to_string(),
23			description: "Change Data Capture module".to_string(),
24			r#type: ComponentType::Module,
25		}
26	}
27}