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

//! Definitions for live collections, which offer the core APIs for writing distributed applications.
//!
//! Traditional programs (like those in Rust) typically manipulate **collections** of data elements,
//! such as those stored in a `Vec` or `HashMap`. These collections are **fixed** in the sense that
//! any transformations applied to them such as `map` are immediately executed on a snapshot of the
//! collection. This means that the output will not be updated when the input collection is modified.
//!
//! In Hydro, programs instead work with **live collections** which are expected to dynamically
//! change over time as new elements are added or removed (in response to API requests, streaming
//! ingestion, etc). Applying a transformation like `map` to a live collection results in another live
//! collection that will dynamically change over time. All network inputs and outputs in Hydro are
//! handled via live collections, so the majority of application logic written with Hydro will involve
//! manipulating live collections.
//!
//! See the [Hydro docs](https://hydro.run/docs/hydro/reference/live-collections) for more.

pub mod boundedness;

pub mod keyed_singleton;
#[doc(inline)]
pub use keyed_singleton::KeyedSingleton;

pub mod keyed_stream;
#[doc(inline)]
pub use keyed_stream::KeyedStream;

pub mod optional;
#[doc(inline)]
pub use optional::Optional;

pub mod singleton;
#[doc(inline)]
pub use singleton::Singleton;

pub mod stream;
#[doc(inline)]
pub use stream::Stream;

pub mod sliced;

#[doc(hidden)]
pub mod batch_atomic;