List of all items
Structs
- bytes::arc::Bytes
- communication::Message
- communication::WorkerGuards
- communication::allocator::Process
- communication::allocator::Thread
- communication::allocator::canary::Canary
- communication::allocator::counters::ArcPusher
- communication::allocator::counters::Puller
- communication::allocator::counters::Pusher
- communication::allocator::process::Process
- communication::allocator::process::ProcessBuilder
- communication::allocator::thread::Puller
- communication::allocator::thread::Pusher
- communication::allocator::thread::Thread
- communication::allocator::thread::ThreadBuilder
- communication::allocator::zero_copy::allocator::TcpAllocator
- communication::allocator::zero_copy::allocator::TcpBuilder
- communication::allocator::zero_copy::allocator_process::ProcessAllocator
- communication::allocator::zero_copy::allocator_process::ProcessBuilder
- communication::allocator::zero_copy::bytes_exchange::MergeQueue
- communication::allocator::zero_copy::bytes_exchange::SendEndpoint
- communication::allocator::zero_copy::bytes_slab::BytesSlab
- communication::allocator::zero_copy::initialize::CommsGuard
- communication::allocator::zero_copy::push_pull::Puller
- communication::allocator::zero_copy::push_pull::PullerInner
- communication::allocator::zero_copy::push_pull::Pusher
- communication::buzzer::Buzzer
- communication::initialize::WorkerGuards
- communication::logging::CommunicationSetup
- communication::logging::MessageEvent
- communication::logging::StateEvent
- communication::message::Message
- communication::networking::MessageHeader
- container::CapacityContainerBuilder
- container::columnation::ColumnStack
- container::columnation::CopyRegion
- container::columnation::StableRegion
- container::columnation::TimelyStack
- container::flatcontainer::ColumnsRegion
- container::flatcontainer::CopyIter
- container::flatcontainer::FlatStack
- container::flatcontainer::Iter
- container::flatcontainer::MirrorRegion
- container::flatcontainer::OptionRegion
- container::flatcontainer::OwnedRegion
- container::flatcontainer::ResultRegion
- container::flatcontainer::SliceRegion
- container::flatcontainer::StringRegion
- container::flatcontainer::impls::codec::BytesMap
- container::flatcontainer::impls::codec::CodecRegion
- container::flatcontainer::impls::codec::DictionaryCodec
- container::flatcontainer::impls::codec::MisraGries
- container::flatcontainer::impls::columns::ColumnsRegion
- container::flatcontainer::impls::columns::ReadColumns
- container::flatcontainer::impls::columns::ReadColumnsIter
- container::flatcontainer::impls::columns::ReadColumnsIterInner
- container::flatcontainer::impls::deduplicate::CollapseSequence
- container::flatcontainer::impls::deduplicate::ConsecutiveOffsetPairs
- container::flatcontainer::impls::huffman_container::HuffmanContainer
- container::flatcontainer::impls::mirror::MirrorRegion
- container::flatcontainer::impls::offsets::OffsetList
- container::flatcontainer::impls::offsets::OffsetOptimized
- container::flatcontainer::impls::option::OptionRegion
- container::flatcontainer::impls::result::ResultRegion
- container::flatcontainer::impls::slice::ReadSlice
- container::flatcontainer::impls::slice::ReadSliceIter
- container::flatcontainer::impls::slice::ReadSliceIterInner
- container::flatcontainer::impls::slice::SliceRegion
- container::flatcontainer::impls::slice_copy::OwnedRegion
- container::flatcontainer::impls::string::StringRegion
- container::flatcontainer::impls::tuple::TupleABCDEFGHIJKLMNOPRegion
- container::flatcontainer::impls::tuple::TupleABCDEFGHIJKLMNORegion
- container::flatcontainer::impls::tuple::TupleABCDEFGHIJKLMNRegion
- container::flatcontainer::impls::tuple::TupleABCDEFGHIJKLMRegion
- container::flatcontainer::impls::tuple::TupleABCDEFGHIJKLRegion
- container::flatcontainer::impls::tuple::TupleABCDEFGHIJKRegion
- container::flatcontainer::impls::tuple::TupleABCDEFGHIJRegion
- container::flatcontainer::impls::tuple::TupleABCDEFGHIRegion
- container::flatcontainer::impls::tuple::TupleABCDEFGHRegion
- container::flatcontainer::impls::tuple::TupleABCDEFGRegion
- container::flatcontainer::impls::tuple::TupleABCDEFRegion
- container::flatcontainer::impls::tuple::TupleABCDERegion
- container::flatcontainer::impls::tuple::TupleABCDRegion
- container::flatcontainer::impls::tuple::TupleABCRegion
- container::flatcontainer::impls::tuple::TupleABRegion
- container::flatcontainer::impls::tuple::TupleARegion
- dataflow::channels::Message
- dataflow::channels::pact::ExchangeCore
- dataflow::channels::pact::LogPuller
- dataflow::channels::pact::LogPusher
- dataflow::channels::pact::Pipeline
- dataflow::channels::pullers::counter::ConsumedGuard
- dataflow::channels::pullers::counter::Counter
- dataflow::channels::pushers::buffer::AutoflushSession
- dataflow::channels::pushers::buffer::Buffer
- dataflow::channels::pushers::buffer::Session
- dataflow::channels::pushers::counter::Counter
- dataflow::channels::pushers::exchange::Exchange
- dataflow::channels::pushers::tee::Tee
- dataflow::channels::pushers::tee::TeeHelper
- dataflow::operators::ActivateCapability
- dataflow::operators::Capability
- dataflow::operators::CapabilitySet
- dataflow::operators::DowngradeError
- dataflow::operators::InputCapability
- dataflow::operators::core::capture::event::binary::EventReader
- dataflow::operators::core::capture::event::binary::EventWriter
- dataflow::operators::core::capture::event::link::EventLink
- dataflow::operators::core::feedback::Handle
- dataflow::operators::core::input::Handle
- dataflow::operators::core::probe::Handle
- dataflow::operators::core::unordered_input::UnorderedHandle
- dataflow::operators::flow_controlled::IteratorSourceInput
- dataflow::operators::generic::FrontierNotificator
- dataflow::operators::generic::FrontieredInputHandleCore
- dataflow::operators::generic::InputHandleCore
- dataflow::operators::generic::Notificator
- dataflow::operators::generic::OperatorInfo
- dataflow::operators::generic::OutputHandleCore
- dataflow::operators::generic::OutputWrapper
- dataflow::operators::generic::builder_raw::OperatorBuilder
- dataflow::operators::generic::builder_raw::OperatorShape
- dataflow::operators::generic::builder_rc::OperatorBuilder
- dataflow::scopes::child::Child
- dataflow::stream::StreamCore
- execute::Config
- logging::ApplicationEvent
- logging::BatchLogger
- logging::ChannelsEvent
- logging::CommChannelsEvent
- logging::GuardedMessageEvent
- logging::GuardedProgressEvent
- logging::InputEvent
- logging::MessagesEvent
- logging::OperatesEvent
- logging::PushProgressEvent
- logging::ScheduleEvent
- logging::ShutdownEvent
- logging::TimelyProgressEvent
- logging::TimelySetup
- logging_core::Logger
- logging_core::Registry
- order::FlatProductRegion
- order::Product
- progress::Location
- progress::Source
- progress::Target
- progress::broadcast::Progcaster
- progress::change_batch::ChangeBatch
- progress::frontier::Antichain
- progress::frontier::AntichainRef
- progress::frontier::MutableAntichain
- progress::operate::SharedProgress
- progress::reachability::Builder
- progress::reachability::PerOperator
- progress::reachability::PortInformation
- progress::reachability::Tracker
- progress::reachability::logging::SourceUpdate
- progress::reachability::logging::TargetUpdate
- progress::reachability::logging::TrackerLogger
- progress::subgraph::Subgraph
- progress::subgraph::SubgraphBuilder
- scheduling::activate::ActivateOnDrop
- scheduling::activate::Activations
- scheduling::activate::Activator
- scheduling::activate::SyncActivationError
- scheduling::activate::SyncActivations
- scheduling::activate::SyncActivator
- synchronization::barrier::Barrier
- synchronization::sequence::Sequencer
- worker::Config
- worker::Worker
Enums
- CommunicationConfig
- communication::Allocator
- communication::Config
- communication::allocator::Generic
- communication::allocator::GenericBuilder
- communication::allocator::generic::Generic
- communication::allocator::generic::GenericBuilder
- communication::initialize::Config
- communication::logging::CommunicationEvent
- communication::message::RefOrMut
- container::flatcontainer::impls::offsets::OffsetStride
- dataflow::operators::core::capture::event::Event
- logging::CommChannelKind
- logging::ParkEvent
- logging::StartStop
- logging::TimelyEvent
- progress::Port
- progress::reachability::logging::TrackerEvent
- worker::ProgressMode
Traits
- Container
- Data
- ExchangeData
- communication::Allocate
- communication::Data
- communication::Pull
- communication::Push
- communication::allocator::Allocate
- communication::allocator::AllocateBuilder
- communication::allocator::zero_copy::bytes_exchange::BytesPull
- communication::allocator::zero_copy::bytes_exchange::BytesPush
- communication::allocator::zero_copy::stream::Stream
- container::Container
- container::ContainerBuilder
- container::PushInto
- container::PushPartitioned
- container::SizableContainer
- container::columnation::Columnation
- container::columnation::Region
- container::flatcontainer::Index
- container::flatcontainer::IntoOwned
- container::flatcontainer::Push
- container::flatcontainer::Region
- container::flatcontainer::RegionPreference
- container::flatcontainer::ReserveItems
- container::flatcontainer::impls::codec::Codec
- container::flatcontainer::impls::offsets::OffsetContainer
- dataflow::channels::pact::ParallelizationContract
- dataflow::operators::aggregation::aggregate::Aggregate
- dataflow::operators::aggregation::state_machine::StateMachine
- dataflow::operators::branch::Branch
- dataflow::operators::branch::BranchWhen
- dataflow::operators::broadcast::Broadcast
- dataflow::operators::core::capture::capture::Capture
- dataflow::operators::core::capture::event::EventIterator
- dataflow::operators::core::capture::event::EventPusher
- dataflow::operators::core::capture::extract::Extract
- dataflow::operators::core::capture::replay::Replay
- dataflow::operators::core::concat::Concat
- dataflow::operators::core::concat::Concatenate
- dataflow::operators::core::enterleave::Enter
- dataflow::operators::core::enterleave::Leave
- dataflow::operators::core::exchange::Exchange
- dataflow::operators::core::feedback::ConnectLoop
- dataflow::operators::core::feedback::Feedback
- dataflow::operators::core::feedback::LoopVariable
- dataflow::operators::core::filter::Filter
- dataflow::operators::core::input::Input
- dataflow::operators::core::inspect::Inspect
- dataflow::operators::core::inspect::InspectCore
- dataflow::operators::core::map::Map
- dataflow::operators::core::ok_err::OkErr
- dataflow::operators::core::probe::Probe
- dataflow::operators::core::rc::SharedStream
- dataflow::operators::core::reclock::Reclock
- dataflow::operators::core::to_stream::ToStream
- dataflow::operators::core::to_stream::ToStreamBuilder
- dataflow::operators::core::unordered_input::UnorderedInput
- dataflow::operators::count::Accumulate
- dataflow::operators::delay::Delay
- dataflow::operators::filter::Filter
- dataflow::operators::generic::operator::Operator
- dataflow::operators::input::Input
- dataflow::operators::map::Map
- dataflow::operators::partition::Partition
- dataflow::operators::result::ResultStream
- dataflow::operators::to_stream::ToStream
- dataflow::operators::unordered_input::UnorderedInput
- dataflow::scopes::Scope
- dataflow::scopes::ScopeParent
- dataflow::stream::AsStream
- logging::ProgressEventTimestamp
- logging::ProgressEventTimestampVec
- order::Empty
- order::PartialOrder
- order::TotalOrder
- progress::frontier::MutableAntichainFilter
- progress::operate::Operate
- progress::timestamp::PathSummary
- progress::timestamp::Refines
- progress::timestamp::Timestamp
- scheduling::Schedule
- scheduling::Scheduler
- scheduling::activate::Scheduler
- worker::AsWorker
Macros
Functions
- communication::allocator::zero_copy::allocator::new_vector
- communication::allocator::zero_copy::initialize::initialize_networking
- communication::allocator::zero_copy::initialize::initialize_networking_from_sockets
- communication::allocator::zero_copy::tcp::recv_loop
- communication::allocator::zero_copy::tcp::send_loop
- communication::initialize
- communication::initialize::initialize
- communication::initialize::initialize_from
- communication::initialize_from
- communication::networking::await_connections
- communication::networking::create_sockets
- communication::networking::start_connections
- container::buffer::default_capacity
- dataflow::operators::flow_controlled::iterator_source
- dataflow::operators::generic::operator::empty
- dataflow::operators::generic::operator::source
- execute::example
- execute::execute
- execute::execute_directly
- execute::execute_from
- execute::execute_from_args
Type Aliases
- communication::allocator::thread::ThreadPuller
- communication::allocator::thread::ThreadPusher
- dataflow::channels::Bundle
- dataflow::channels::pact::Exchange
- dataflow::operators::generic::FrontieredInputHandle
- dataflow::operators::generic::InputHandle
- dataflow::operators::generic::OutputHandle
- dataflow::operators::input::Handle
- dataflow::operators::unordered_input::UnorderedHandle
- dataflow::scopes::child::Iterative
- dataflow::stream::Stream
- logging::Logger
- logging::TimelyLogger
- logging::TimelyProgressLogger
- logging::WorkerIdentifier
- progress::broadcast::ProgressMsg
- progress::broadcast::ProgressVec