List of all items

Structs

• channels::ChannelStats
• channels::bounded::BoundedReceiver
• channels::bounded::BoundedSender
• channels::broadcast::BroadcastReceiver
• channels::broadcast::BroadcastSender
• channels::newest::NewestReceiver
• channels::newest::NewestSender
• channels::unbounded::UnboundedReceiver
• channels::unbounded::UnboundedSender
• clock::Tick
• clock::TickClock
• errors::CoreError
• ids::ChannelId
• ids::EdgeId
• ids::NodeId
• ids::PortId
• ids::RunId
• ids::TickId
• messages::Message
• messages::MessageMeta
• messages::Sequence
• messages::Token
• messages::TokenGenerator
• messages::Watermark
• sync::SyncGroup

Enums

• channels::Backpressure
• channels::CloseBehavior
• channels::RecvOutcome
• channels::policy::EdgePolicy
• compute::ComputeAffinity
• errors::CoreErrorCode
• policy::BackpressureStrategy
• sync::SyncPolicy

Traits

• channels::ChannelRecv
• channels::ChannelSend

Functions

• channels::bounded::bounded
• channels::bounded::bounded_with_behavior
• channels::broadcast::broadcast
• channels::broadcast::broadcast_with_behavior
• channels::newest::newest
• channels::newest::newest_with_behavior
• channels::policy::build_bounded
• channels::policy::build_broadcast
• channels::policy::build_newest
• channels::policy::build_unbounded
• channels::unbounded::unbounded
• channels::unbounded::unbounded_with_behavior

Type Aliases

• errors::CoreResult