List of all items
Structs
- AddOp
- AsyncScheduler
- AsyncSchedulerBuilder
- AsyncSchedulerConfig
- AsyncSchedulerConfigBuilder
- ConstantOp
- DoubleOutOp
- DoubleToTriOp
- DoubleToTriTwoGenericsOp
- FailingOperator
- InFlightCounter
- IncrementOperator
- Merge2Op
- MockCheckpointCallback
- MockCheckpointCallbackBuilder
- MultiplyOp
- Network
- NetworkBuilder
- NetworkEdge
- NetworkEdgeBuilder
- NetworkNode
- NetworkNodeBuilder
- NoOpCheckpointCallback
- NoOpOperator
- PerformanceStats
- QuadToQuadOp
- SharedCompletedNodes
- SingleChannelPassthroughOperator
- SingleToTriOp
- SingleValOp
- SinkOperator
- SplitAndDoubleOp
- StreamyOperator
- TaskItem
- TaskItemBuilder
- TaskResult
- TaskResultBuilder
- TestWire
- TriToQuadOp
- TriToSingleOp
- WorkerPool
- WorkerPoolBuilder
- unsafe_erased::Erased
Enums
- AddOpIO
- AsyncSchedulerBuilderError
- AsyncSchedulerConfigBuilderError
- BasicOpCode
- BatchingStrategy
- ConstantOpIO
- DoubleOutOpIO
- DoubleToTriOpIO
- DoubleToTriTwoGenericsOpIO
- FailingOperatorIO
- FreedChildReceivedOperationOutcome
- IncrementOperatorIO
- InsertOutcome
- Merge2OpIO
- MockCheckpointCallbackBuilderError
- MultiplyOpIO
- NetworkBuilderError
- NetworkEdgeBuilderError
- NetworkError
- NetworkNodeBuilderError
- NoOpOperatorIO
- OperatorFailureReason
- QuadToQuadOpIO
- ReadyNodeReceivedOperationOutcome
- SingleChannelPassthroughOperatorIO
- SingleToTriOpIO
- SingleValOpIO
- SinkOperatorIO
- SplitAndDoubleOpIO
- StreamyOperatorIO
- TaskItemBuilderError
- TaskResultBuilderError
- TestWireIO
- TriToQuadOpIO
- TriToSingleOpIO
- WorkerPoolBuilderError
- unsafe_erased::DowncastError
Traits
- CheckpointCallback
- IntoArcOperator
- OpCode
- Operator
- OperatorSignature
- PortTryFrom0
- PortTryFrom1
- PortTryFrom2
- PortTryFrom3
- PortTryInto0
- PortTryInto0Any
- PortTryInto1
- PortTryInto1Any
- PortTryInto2
- PortTryInto2Any
- PortTryInto3
- PortTryInto3Any
Macros
- edge
- network
- node
- task_item
- test_wire_port0_into
- test_wire_port1_into
- test_wire_port2_into
- test_wire_port3_into
- try_build_async_scheduler_config
Attribute Macros
Derive Macros
Functions
- aggregator_thread_behavior
- build_and_send_task_result
- check_all_nodes_done
- clear_checkpoint_invocations
- compute_freed_children
- create_worker_channels
- current_memory_usage_in_bytes
- drain_channel
- execute_node
- fetch_next_task
- get_mock_checkpoint_invocations
- handle_freed_children
- mock_failing_operator_task
- mock_permit
- mock_task_with_checkpoint
- poll_worker_results
- process_immediate
- process_immediate_freed_child_received
- process_immediate_ready_node_received
- process_task
- process_waves
- read_next_wave
- release_concurrency
- spawn_aggregator
- spawn_aggregator_and_workers
- spawn_worker_thread
- submit_chunk_to_worker_pool
- validate_network
- wait_until_all_tasks_in_chunk_are_done
- wire_up_network
- worker_main_loop