Module dispatch

Macros

• for_all_dispatcher_variants 🔒
• impl_dispatcher 🔒

Structs

• BroadcastDispatcher
  BroadcastDispatcher dispatches message to all outputs.
• DispatchExecutor
  DispatchExecutor consumes 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.
• DispatchExecutorInner 🔒
• DispatchExecutorMetrics 🔒
• DispatcherWithMetrics 🔒
• HashDataDispatcher
• RoundRobinDataDispatcher
• SimpleDispatcher
  SimpleDispatcher dispatches message to a single output.

Enums

• DispatcherImpl

Traits

• Dispatcher

Functions

• broadcast_concurrent 🔒
  Concurrently broadcast a message to all outputs.
• try_batch_barriers 🔒
  Tries to batch up to max_barrier_count_per_batch consecutive barriers within a single message batch.

Trait Aliases

• DispatchFuture