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.

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.