hydro_lang/sim/
mod.rs

1//! Deterministic simulation testing support for Hydro programs.
2//!
3//! See [`crate::compile::builder::FlowBuilder::sim`] and [`crate::sim::flow::SimFlow`] for more details.
4
5use std::marker::PhantomData;
6
7use serde::Serialize;
8use serde::de::DeserializeOwned;
9
10use crate::compile::builder::ExternalPortId;
11use crate::live_collections::stream::{Ordering, Retries};
12
13/// A receiver for an external bincode stream in a simulation.
14pub struct SimReceiver<T: Serialize + DeserializeOwned, O: Ordering, R: Retries>(
15    pub(crate) ExternalPortId,
16    pub(crate) PhantomData<(T, O, R)>,
17);
18
19/// A sender to an external bincode sink in a simulation.
20pub struct SimSender<T: Serialize + DeserializeOwned, O: Ordering, R: Retries>(
21    pub(crate) ExternalPortId,
22    pub(crate) PhantomData<(T, O, R)>,
23);
24
25/// A receiver for an external cluster stream in a simulation.
26///
27/// Each received value is a `(u32, T)` tuple where the `u32` is the raw
28/// cluster member ID that produced the value.
29pub struct SimClusterReceiver<T: Serialize + DeserializeOwned, O: Ordering, R: Retries>(
30    pub(crate) ExternalPortId,
31    pub(crate) PhantomData<(T, O, R)>,
32);
33
34/// A sender to an external cluster sink in a simulation.
35///
36/// Each sent value is a `(u32, T)` tuple where the `u32` is the raw
37/// cluster member ID that should receive the value.
38pub struct SimClusterSender<T: Serialize + DeserializeOwned, O: Ordering, R: Retries>(
39    pub(crate) ExternalPortId,
40    pub(crate) PhantomData<(T, O, R)>,
41);
42
43/// A sender for an atomic input in a simulation.
44///
45/// `send_atomic` is synchronous — the value is immediately available in
46/// the next atomic slice without requiring a separate tick.
47pub struct SimAtomicSender<T: Serialize + DeserializeOwned, O: Ordering, R: Retries>(
48    pub(crate) SimSender<T, O, R>,
49);
50
51#[cfg(stageleft_runtime)]
52mod builder;
53
54#[cfg(stageleft_runtime)]
55pub mod compiled;
56
57#[cfg(stageleft_runtime)]
58pub(crate) mod graph;
59
60#[cfg(stageleft_runtime)]
61pub mod flow;
62
63#[cfg(stageleft_runtime)]
64#[doc(hidden)]
65pub mod runtime;
66
67#[cfg(test)]
68mod tests;
hydro_lang/sim/mod.rs

hydro_lang/sim/
mod.rs
