Module dataflow_types::sources::persistence [−][src]
Structs
The details needed to make a source that uses an external super::SourceConnector
persistent.
Enums
The persistence details we need for persisting a source envelopes data structures.
Structure wrapping a timestamp update from a source If RT, contains a partition count which informs workers that messages with Offset on PartititionId will be timestamped with Timestamp.