Macros§
Structs§
- Broadcast
Dispatcher BroadcastDispatcherdispatches message to all outputs.- Dispatch
Executor DispatchExecutorconsumes messages and send them into downstream actors. Usually, data chunks will be dispatched with some specified policy, while control message such as barriers will be distributed to all receivers.- Dispatch
Executor 🔒Inner - Dispatch
Executor 🔒Metrics - Dispatcher
With 🔒Metrics - Hash
Data Dispatcher - Round
Robin Data Dispatcher - Simple
Dispatcher SimpleDispatcherdispatches message to a single output.
Enums§
Traits§
Functions§
- broadcast_
concurrent 🔒 - Concurrently broadcast a message to all outputs.
- try_
batch_ 🔒barriers - Tries to batch up to
max_barrier_count_per_batchconsecutive barriers within a single message batch.