Skip to main content

reifydb_core/actors/
watermark.rs

1// SPDX-License-Identifier: Apache-2.0
2// Copyright (c) 2025 ReifyDB
3
4use std::sync::Arc;
5
6use reifydb_runtime::sync::waiter::WaiterHandle;
7
8/// Messages for the watermark actor
9#[derive(Debug)]
10pub enum WatermarkMessage {
11	Begin {
12		version: u64,
13	},
14	Done {
15		version: u64,
16	},
17	WaitFor {
18		version: u64,
19		waiter: Arc<WaiterHandle>,
20	},
21}