Module tempest_source::prelude

Re-exports

pub use config;

Macros

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.

Structs

SourceError
SourceMsg	Data structure for representing a message as it moves through a topology

Enums

SourceAckPolicy	Ack policy configuration options
SourceErrorKind	Wrapper for handling source error states
SourceInterval	Source interval enum time value

Traits

Source	Source trait is used define actions
SourceBuilder	SourceBuilder trait for defining how to configure structs that implements the Source trait.

Functions

now_millis

Helper function for returning the current system time as epoch milliseconds

Type Definitions

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