List of all items

Structs

• Message
• bytes::arc::Bytes
• 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::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
• 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::Bytesable
• communication::Exchangeable
• communication::Pull
• communication::Push
• communication::allocator::Allocate
• communication::allocator::AllocateBuilder
• communication::allocator::Exchangeable
• 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

• container::columnation::tuple_column_stack

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

Constants

• container::buffer::BUFFER_SIZE_BYTES