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
- props::Consecutive
- props::Duplicates
- props::Monotonic
- props::NoDuplicates
- props::NonMonotonic
- 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
- util::DroppableChild
- util::MonotonicFn
- util::Morphism
- util::clear::ClearDefault
- util::cli::ConnectedDemux
- util::cli::ConnectedDirect
- util::cli::ConnectedTagged
- util::cli::DemuxDrain
- util::cli::HydroCLI
- util::cli::MergeSource
- util::cli::TaggedSource
- util::monotonic_map::MonotonicMap
- util::multiset::HashMultiSet
- 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::cli::BoundConnection
- util::cli::RealizedServerPort
- util::cli::ServerBindConfig
- util::cli::ServerOrBound
- util::cli::ServerPort
- util::unsync::mpsc::TrySendError
Traits
- compiled::pull::HalfJoinState
- props::PropDuplicates
- props::PropMonotonicity
- props::Props
- props::Spec
- props::wrap::PullSpec
- props::wrap::PushSpec
- 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::cli::Connected
- util::cli::ConnectedSink
- util::cli::ConnectedSource
- util::cli::StreamSink
- util::demux_enum::DemuxEnum
- util::demux_enum::DemuxEnumItems
- util::demux_enum::PusheratorListForItems
Macros
- assert_var_impl
- datalog
- hydroflow_expect_warnings
- hydroflow_parser
- hydroflow_syntax
- hydroflow_syntax_noemit
- launch
- monotonic_fn
- morphism
- rassert
- rassert_eq
- util::cli::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::cli::init
- util::cli::init_no_ack_start
- util::cli::launch_flow
- util::collect_ready
- util::collect_ready_async
- util::connect_tcp
- util::connect_tcp_bytes
- util::connect_tcp_lines
- 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::cli::BufferedDrain
- util::cli::DynSink
- util::cli::DynStream
- util::cli::DynStreamSink
- util::cli::InitConfig