Module dispatch 

Re-exports

pub use dispatch_sync_log_store::SyncLogStoreDispatchExecutor;

pub use output_mapping::DispatchOutputMapping;

Modules

dispatch_sync_log_store 🔒

output_mapping 🔒

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.

dispatch_message_batch 🔒

Dispatches a message batch downstream and returns the barriers that should be yielded by the barrier stream.

try_batch_barriers 🔒

Tries to batch up to max_barrier_count_per_batch consecutive barriers within a single message batch.

Trait Aliases

DispatchFuture