hydroflow_plus 0.10.0

Functional programming API for hydroflow
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

#![feature(box_patterns)]

stageleft::stageleft_no_entry_crate!();

pub use hydroflow::scheduled::graph::Hydroflow;
pub use hydroflow::*;
pub use stageleft::*;

pub mod runtime_support {
    pub use bincode;
}

pub mod runtime_context;
pub use runtime_context::RuntimeContext;

pub mod stream;
pub use stream::{Bounded, Stream, Unbounded};

pub mod singleton;
pub use singleton::Singleton;

pub mod optional;
pub use optional::Optional;

pub mod location;
pub use location::{Cluster, ClusterId, Location, Process, Tick};

pub mod deploy;
pub use deploy::{ClusterSpec, Deploy, ProcessSpec};

pub mod cycle;

pub mod builder;
pub use builder::FlowBuilder;

pub mod ir;

pub mod rewrites;

mod staging_util;

#[stageleft::runtime]
#[cfg(test)]
mod tests {
    #[ctor::ctor]
    fn init() {
        crate::deploy::init_test();
    }
}