Module dataflow_types::types::sources::persistence

Structs

SourcePersistDesc

The details needed to make a source that uses an external super::SourceConnector persistent.

Enums

EnvelopePersistDesc

The persistence details we need for persisting a source envelopes data structures.

TimestampSourceUpdate

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.