Module prelude
Source pub use config;
- debug
- Logs a message at the debug level.
- error
- Logs a message at the error level.
- info
- Logs a message at the info level.
- log
- The standard logging macro.
- trace
- Logs a message at the trace level.
- warn
- Logs a message at the warn level.
- SourceError
- SourceMsg
- Data structure for representing a message as it moves through
a topology
- SourceAckPolicy
- Ack policy configuration options
- SourceErrorKind
- Wrapper for handling source error states
- SourceInterval
- Source interval enum time value
- Source
Source trait is used define actions- SourceBuilder
SourceBuilder trait for defining how to configure
structs that implements the Source trait.
- now_millis
- Helper function for returning the current system time as epoch milliseconds
- Msg
- Source type for representing messages
- MsgId
- All messages must have a unique message id
This value is used to ack messages
- SourcePollResult
- Return type for polled sources
- SourceResult
- Generic return type