hydro_lang 0.16.0

A Rust framework for correct and performant distributed systems
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60

//! Deterministic simulation testing support for Hydro programs.
//!
//! See [`crate::compile::builder::FlowBuilder::sim`] and [`crate::sim::flow::SimFlow`] for more details.

use std::marker::PhantomData;

use serde::Serialize;
use serde::de::DeserializeOwned;

use crate::compile::builder::ExternalPortId;
use crate::live_collections::stream::{Ordering, Retries};

/// A receiver for an external bincode stream in a simulation.
pub struct SimReceiver<T: Serialize + DeserializeOwned, O: Ordering, R: Retries>(
    pub(crate) ExternalPortId,
    pub(crate) PhantomData<(T, O, R)>,
);

/// A sender to an external bincode sink in a simulation.
pub struct SimSender<T: Serialize + DeserializeOwned, O: Ordering, R: Retries>(
    pub(crate) ExternalPortId,
    pub(crate) PhantomData<(T, O, R)>,
);

/// A receiver for an external cluster stream in a simulation.
///
/// Each received value is a `(u32, T)` tuple where the `u32` is the raw
/// cluster member ID that produced the value.
pub struct SimClusterReceiver<T: Serialize + DeserializeOwned, O: Ordering, R: Retries>(
    pub(crate) ExternalPortId,
    pub(crate) PhantomData<(T, O, R)>,
);

/// A sender to an external cluster sink in a simulation.
///
/// Each sent value is a `(u32, T)` tuple where the `u32` is the raw
/// cluster member ID that should receive the value.
pub struct SimClusterSender<T: Serialize + DeserializeOwned, O: Ordering, R: Retries>(
    pub(crate) ExternalPortId,
    pub(crate) PhantomData<(T, O, R)>,
);

#[cfg(stageleft_runtime)]
mod builder;

#[cfg(stageleft_runtime)]
pub mod compiled;

#[cfg(stageleft_runtime)]
pub(crate) mod graph;

#[cfg(stageleft_runtime)]
pub mod flow;

#[cfg(stageleft_runtime)]
#[doc(hidden)]
pub mod runtime;

#[cfg(test)]
mod tests;