[−][src]Module tempest::prelude
Base imports for implementing and running topologies
Re-exports
pub use crate::common::now_millis; |
pub use crate::metric; |
pub use crate::metric::MetricLogLevel; |
pub use crate::metric::MetricTarget; |
pub use crate::pipeline::Pipeline; |
pub use crate::rt; |
pub use crate::rt::run; |
pub use crate::task; |
pub use crate::topology::Topology; |
pub use crate::topology::TopologyBuilder; |
pub use crate::topology::TopologyFailurePolicy; |
pub use crate::topology::TopologyOptions; |
Modules
config | Config organizes hierarchical or layered configurations for Rust applications. |
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 |
|
SourceBuilder |
|
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 |