Module input

Modules

local_input 🔒

remote_input 🔒

Structs

LocalInput

LocalInput receives data from a local channel.

RemoteInput

RemoteInput connects to the upstream exchange server and receives data with gRPC.

Traits

Input

Input provides an interface for MergeExecutor and ReceiverExecutor to receive data from upstream actors.

Functions

apply_dispatcher_barrier 🔒

assert_equal_dispatcher_barrier 🔒

new_input 🔒

Create a LocalInput or RemoteInput instance with given info. Used by merge executors and receiver executors.

process_dispatcher_msg 🔒

Type Aliases

BoxedInput