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 is a more abstract upstream input type, used for DynamicReceivers type handling of multiple upstream inputs

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

BoxedActorInput

BoxedInput

Trait Aliases

ActorInput

ActorInput provides an interface for MergeExecutor and ReceiverExecutor to receive data from upstream actors. Only used for actor inputs.