reifydb_flow/timer/
mod.rs1use reifydb_codec::key::encoded::EncodedKey;
5use reifydb_core::{interface::catalog::flow::OperatorId, state::store::TimerKind};
6use reifydb_value::value::datetime::DateTime;
7
8#[cfg(feature = "runtime")]
9pub mod extension;
10#[cfg(feature = "runtime")]
11pub mod registry;
12#[cfg(feature = "runtime")]
13pub mod wheel;
14
15#[derive(Debug, Clone, PartialEq, Eq)]
16pub struct Timer {
17 pub due: DateTime,
18 pub kind: TimerKind,
19 pub key: EncodedKey,
20}
21
22#[derive(Debug, Clone, Copy, PartialEq, Eq, Hash, PartialOrd, Ord)]
23pub struct TimerDue {
24 pub operator_id: OperatorId,
25 pub due: DateTime,
26}