Enum dataflow_types::sources::persistence::TimestampSourceUpdate [−][src]
pub enum TimestampSourceUpdate {
RealTime(PartitionId),
}
Expand description
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.
Variants
RealTime(PartitionId)
Tuple Fields
0: PartitionId
Update for an RT source: contains a new partition to add to this source.
Trait Implementations
fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error> where
__D: Deserializer<'de>,
fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error> where
__D: Deserializer<'de>,
Deserialize this value from the given Serde deserializer. Read more
Auto Trait Implementations
impl RefUnwindSafe for TimestampSourceUpdate
impl Send for TimestampSourceUpdate
impl Sync for TimestampSourceUpdate
impl Unpin for TimestampSourceUpdate
impl UnwindSafe for TimestampSourceUpdate
Blanket Implementations
Mutably borrows from an owned value. Read more
Attaches the provided Subscriber
to this type, returning a
WithDispatch
wrapper. Read more
Attaches the current default Subscriber
to this type, returning a
WithDispatch
wrapper. Read more