List of all items
Structs
- compiled::pull::AntiJoin
- compiled::pull::CrossJoin
- compiled::pull::CrossJoinState
- compiled::pull::HalfJoinStateFold
- compiled::pull::HalfJoinStateFoldFrom
- compiled::pull::HalfJoinStateReduce
- compiled::pull::HalfMultisetJoinState
- compiled::pull::HalfSetJoinState
- compiled::pull::SymmetricHashJoin
- scheduled::HandoffId
- scheduled::StateId
- scheduled::SubgraphId
- scheduled::context::Context
- scheduled::graph::Hydroflow
- scheduled::handoff::Iter
- scheduled::handoff::TeeingHandoff
- scheduled::handoff::VecHandoff
- scheduled::input::Buffer
- scheduled::input::Input
- scheduled::net::Message
- scheduled::port::Port
- scheduled::port::PortCtx
- scheduled::query::Operator
- scheduled::query::Query
- scheduled::reactor::Reactor
- scheduled::state::StateHandle
- scheduled::state::StateHandleErased
- scheduled::ticks::TickDuration
- scheduled::ticks::TickInstant
- util::DroppableChild
- util::MonotonicFn
- util::Morphism
- util::clear::ClearDefault
- util::deploy::ConnectedDemux
- util::deploy::ConnectedDirect
- util::deploy::ConnectedTagged
- util::deploy::DemuxDrain
- util::deploy::DeployPorts
- util::deploy::MergeSource
- util::deploy::TaggedSource
- util::monotonic_map::MonotonicMap
- util::multiset::HashMultiSet
- util::simulation::Address
- util::simulation::Fleet
- util::simulation::Host
- util::simulation::HostBuilder
- util::simulation::Inbox
- util::simulation::Outbox
- util::simulation::TransducerBuilderContext
- util::sparse_vec::SparseVec
- util::unsync::mpsc::Receiver
- util::unsync::mpsc::SendError
- util::unsync::mpsc::Sender
Enums
- scheduled::port::RECV
- scheduled::port::SEND
- util::Persistence
- util::PersistenceKeyed
- util::deploy::BoundConnection
- util::deploy::RealizedServerPort
- util::deploy::ServerBindConfig
- util::deploy::ServerOrBound
- util::deploy::ServerPort
- util::unsync::mpsc::TrySendError
Traits
- compiled::pull::HalfJoinState
- scheduled::graph_ext::GraphExt
- scheduled::handoff::CanReceive
- scheduled::handoff::Handoff
- scheduled::handoff::HandoffMeta
- scheduled::handoff::TryCanReceive
- scheduled::handoff::handoff_list::HandoffList
- scheduled::handoff::handoff_list::PortList
- scheduled::handoff::handoff_list::PortListSplit
- scheduled::input::Give
- scheduled::port::Polarity
- util::clear::Clear
- util::demux_enum::DemuxEnum
- util::demux_enum::DemuxEnumBase
- util::demux_enum::SingleVariant
- util::deploy::Connected
- util::deploy::ConnectedSink
- util::deploy::ConnectedSource
- util::deploy::StreamSink
- util::simulation::MessageSender
Macros
- assert_var_impl
- datalog
- hydroflow_expect_warnings
- hydroflow_parser
- hydroflow_syntax
- hydroflow_syntax_noemit
- launch
- monotonic_fn
- morphism
- rassert
- rassert_eq
- util::deploy::launch
- var_args
- var_expr
- var_type
Attribute Macros
Derive Macros
Functions
- compiled::pull::anti_join_into_iter
- compiled::pull::symmetric_hash_join_into_iter
- util::bind_tcp
- util::bind_tcp_bytes
- util::bind_tcp_lines
- util::bind_udp_bytes
- util::bind_udp_lines
- util::collect_ready
- util::collect_ready_async
- util::connect_tcp
- util::connect_tcp_bytes
- util::connect_tcp_lines
- util::deploy::init
- util::deploy::init_no_ack_start
- util::deploy::launch_flow
- util::deserialize_from_bytes
- util::ipv4_resolve
- util::iter_batches_stream
- util::ready_iter
- util::run_cargo_example
- util::serialize_to_bytes
- util::sort_unstable_by_key_hrtb
- util::tcp_bytes
- util::tcp_bytestream
- util::tcp_framed
- util::tcp_lines
- util::udp_bytes
- util::udp_bytestream
- util::udp_framed
- util::udp_lines
- util::unbounded_channel
- util::unix_bytes
- util::unix_bytestream
- util::unix_framed
- util::unix_lines
- util::unsync::mpsc::bounded
- util::unsync::mpsc::channel
- util::unsync::mpsc::unbounded
- util::unsync_channel
- util::wait_for_process_output
Type Aliases
- Never
- scheduled::net::network_vertex::Address
- scheduled::port::RecvCtx
- scheduled::port::RecvPort
- scheduled::port::SendCtx
- scheduled::port::SendPort
- util::TcpFramedSink
- util::TcpFramedStream
- util::UdpBytesSink
- util::UdpBytesStream
- util::UdpFramedSink
- util::UdpFramedStream
- util::UdpLinesSink
- util::UdpLinesStream
- util::UdpSink
- util::UdpStream
- util::deploy::BufferedDrain
- util::deploy::DynSink
- util::deploy::DynStream
- util::deploy::DynStreamSink
- util::deploy::InitConfig
- util::simulation::Hostname
- util::simulation::MessageWithAddress