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