Struct dataflow::TimestampBindingFeedback [−][src]
pub struct TimestampBindingFeedback {
pub changes: Vec<(GlobalId, ChangeBatch<Timestamp>)>,
pub bindings: Vec<(GlobalId, PartitionId, Timestamp, MzOffset)>,
}
Expand description
Data about timestamp bindings that dataflow workers send to the coordinator
Fields
changes: Vec<(GlobalId, ChangeBatch<Timestamp>)>
Durability frontier changes
bindings: Vec<(GlobalId, PartitionId, Timestamp, MzOffset)>
Timestamp bindings for all of those frontier changes
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 TimestampBindingFeedback
impl Send for TimestampBindingFeedback
impl Sync for TimestampBindingFeedback
impl Unpin for TimestampBindingFeedback
impl UnwindSafe for TimestampBindingFeedback
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