hydroflow 0.10.0

Hydro's low-level dataflow runtime and IR
Documentation 
1
2
3
4
5
6
7
8
9
10
11

use lattices::map_union::MapUnionHashMap;
use lattices::Max;
use serde::{Deserialize, Serialize};

pub type VecClock = MapUnionHashMap<String, Max<usize>>;

#[derive(PartialEq, Eq, Clone, Serialize, Deserialize, Debug)]
pub struct EchoMsg {
    pub payload: String,
    pub vc: VecClock,
}