Crate hydroflow_plus

Source

Re-exports§

pub use runtime_context::RuntimeContext;
pub use stream::Bounded;
pub use stream::Stream;
pub use stream::Unbounded;
pub use singleton::Singleton;
pub use optional::Optional;
pub use location::Cluster;
pub use location::ClusterId;
pub use location::Location;
pub use location::Process;
pub use location::Tick;
pub use deploy::ClusterSpec;
pub use deploy::Deploy;
pub use deploy::ProcessSpec;
pub use builder::FlowBuilder;

Modules§

bincode
Bincode is a crate for encoding and decoding using a tiny binary serialization strategy. Using it, you can easily go from having an object in memory, quickly serialize it to bytes, and then deserialize it back just as fast!
builder
bytes
Provides abstractions for working with bytes.
compiled
Hydroflow’s inner (intra-subgraph) compiled layer.
cycle
deploy
futures
Abstractions for asynchronous programming.
internal
ir
itertools
Extra iterator adaptors, functions and macros.
lang
Hydroflow surface syntax
lattices

The lattices Crate

location
optional
pusherator
Pusherator generics and argument order conventions:
rewrites
runtime_context
runtime_support
rustc_hash
Fast, non-cryptographic hash used by rustc and Firefox.
scheduled
Hydroflow’s outer scheduled layer. Deals with inter-subgraph runtime data-passing and scheduling.
serde
Serde
serde_json
Serde JSON
singleton
stream
tokio
A runtime for writing reliable network applications without compromising speed.
tokio_stream
Stream utilities for Tokio.
tokio_util
Utilities for working with Tokio.
tracing
A scoped, structured logging and diagnostics system.
util
Helper utilities for the Hydroflow surface syntax.
variadics
Variadics
web_time
Description

Macros§

PATH_SEPARATOR
assert_var_impl
Asserts that the variable’s type implements the given traits.
hydroflow_expect_warnings
Tests that the given warnings are emitted by the hydroflow macro invocation.
launch
q
Creates a quoted expression for Hydroflow+.
quse_fn
rassert
assert! but returns a Result<(), String> instead of panicking.
rassert_eq
assert_eq! but returns a Result<(), String> instead of panicking.
stageleft_crate
stageleft_no_entry_crate
var_args
Variadic patterns macro.
var_expr
Variadic expressions (values) macro.
var_type
Variadic types macro.

Structs§

BorrowBounds
Hydroflow
A Hydroflow graph. Owns, schedules, and runs the compiled subgraphs.
RuntimeData
Represents a piece of data that will be passed into the generated code

Traits§

IntoQuotedMut
IntoQuotedOnce
Quoted
QuotedContext

Functions§

quote_type
Captures a fully qualified path to a given type, which is useful when the generated code needs to explicitly refer to a type known at staging time.

Type Aliases§

Never
Stand-in for the nightly “never” type !

Attribute Macros§

entry
Defines an entrypoint for staged code, which will be available as a proc macro. The entrypoint must be a function that returns impl Quoted<T> for some type T.
runtime
Marks a chunk of code as being runtime-only, which means that no staged code in its crate can depend on it. Code behind this attribute is allowed to use staged entrypoints defined in the same crate.
top_level_mod
A utility for declaring top-level public modules in a Stageleft crate that exports macros.