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