hydro_lang/
lib.rs

1#![cfg_attr(docsrs, feature(doc_cfg))]
2
3stageleft::stageleft_no_entry_crate!();
4
5pub use stageleft::q;
6
7#[cfg(feature = "runtime_support")]
8#[cfg_attr(docsrs, doc(cfg(feature = "runtime_support")))]
9#[doc(hidden)]
10pub mod runtime_support {
11    pub use {bincode, dfir_rs, stageleft, tokio};
12    pub mod resource_measurement;
13}
14
15#[doc(hidden)]
16pub mod internal_constants {
17    pub const CPU_USAGE_PREFIX: &str = "CPU:";
18    // Should remain consistent with dfir_lang/src/graph/ops/_counter.rs
19    pub const COUNTER_PREFIX: &str = "_counter";
20}
21
22#[cfg(feature = "dfir_context")]
23#[cfg_attr(docsrs, doc(cfg(feature = "dfir_context")))]
24pub mod runtime_context;
25#[cfg(feature = "dfir_context")]
26#[cfg_attr(docsrs, doc(cfg(feature = "dfir_context")))]
27pub use runtime_context::RUNTIME_CONTEXT;
28
29pub mod unsafety;
30pub use unsafety::*;
31
32pub mod boundedness;
33pub use boundedness::{Bounded, Unbounded};
34
35pub mod stream;
36pub use stream::{NoOrder, Stream, TotalOrder};
37
38pub mod keyed_singleton;
39pub mod keyed_stream;
40pub use keyed_stream::KeyedStream;
41
42pub mod singleton;
43pub use singleton::Singleton;
44
45pub mod optional;
46pub use optional::Optional;
47
48pub mod location;
49pub use location::cluster::CLUSTER_SELF_ID;
50pub use location::{Atomic, Cluster, External, Location, MemberId, NetworkHint, Process, Tick};
51
52#[cfg(feature = "build")]
53#[cfg_attr(docsrs, doc(cfg(feature = "build")))]
54pub mod deploy;
55
56pub mod deploy_runtime;
57
58pub mod cycle;
59
60pub mod builder;
61pub use builder::FlowBuilder;
62
63mod manual_expr;
64
65pub mod ir;
66
67#[cfg(feature = "viz")]
68pub mod graph;
69
70#[cfg(feature = "viz")]
71#[cfg_attr(docsrs, doc(cfg(feature = "viz")))]
72pub mod graph_util;
73
74pub mod rewrites;
75
76mod staging_util;
77
78pub mod backtrace;
79
80#[cfg(feature = "deploy")]
81#[cfg_attr(docsrs, doc(cfg(feature = "deploy")))]
82pub mod test_util;
83
84#[cfg(feature = "build")]
85#[ctor::ctor]
86fn init_rewrites() {
87    stageleft::add_private_reexport(
88        vec!["tokio_util", "codec", "lines_codec"],
89        vec!["tokio_util", "codec"],
90    );
91}
92
93#[cfg(test)]
94mod test_init {
95    #[ctor::ctor]
96    fn init() {
97        crate::deploy::init_test();
98    }
99}
hydro_lang/lib.rs

hydro_lang/
lib.rs
