Macros§
- add_
routine - A simple macro to create a function that returns a coroutine.
- consume
- effect_
alert - effect_
crit - effect_
debug - effect_
emerg - effect_
error - effect_
info - effect_
notice - effect_
warn - output
- terminate
Structs§
- Accumulator
- Broadcast
- An object that received data from a provided
Receiver, and broadcasts the data to all subscribers. - Extractor
- Receives data from an external source and sends the data through a channel.
- Filter
- An object that uses a predicate function to determine whether some data can be passed through a network node
- FnContext
- Funnel
- An object that receives data from multiple subscriber and channels the data to a single output.
- Loader
- An object that receives data from a
Refluxnetwork and sends the data to some external sink. - Message
- Messenger
- Router
- An object that received data from a provided
Receiver, and broadcasts the data to subscribers using a Round Robin algorithm. - Transformer
- An object that enables data mutation. After processing data a
Transformercan yield three variants: - Transformer
Context
Enums§
- Transformer
Effect Type - Transformer
Result - An enum returned from a coroutine sent to a
Transformerobject.