Modulesยง
- local_
input ๐ - remote_
input ๐
Structsยง
- Local
Input LocalInputreceives data from a local channel.- Remote
Input RemoteInputconnects to the upstream exchange server and receives data withgRPC.
Traitsยง
- Input
Inputis a more abstract upstream input type, used forDynamicReceiverstype handling of multiple upstream inputs
Functionsยง
- apply_
dispatcher_ ๐barrier - assert_
equal_ ๐dispatcher_ barrier - new_
input ๐ - Create a
LocalInputorRemoteInputinstance with given info. Used by merge executors and receiver executors.
Type Aliasesยง
Trait Aliasesยง
- Actor
Input ActorInputprovides an interface forMergeExecutorandReceiverExecutorto receive data from upstream actors. Only used for actor inputs.