reifydb_core/event/
cdc.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 crate::{CommitVersion, impl_event, interface::CdcConsumerId};
5
6/// Emitted when a CDC consumer's checkpoint advances to a new version
7#[derive(Debug, Clone)]
8pub struct CdcCheckpointAdvancedEvent {
9	/// The consumer whose checkpoint advanced
10	pub consumer_id: CdcConsumerId,
11	/// The new checkpoint version
12	pub version: CommitVersion,
13}
14
15impl_event!(CdcCheckpointAdvancedEvent);