Enum dataflow_types::TailResponse [−][src]
pub enum TailResponse {
Progress(Antichain<Timestamp>),
Rows(Vec<(Row, Timestamp, Diff)>),
Dropped,
}
Expand description
Various responses that can be communicated about the progress of a TAIL command.
Variants
Progress(Antichain<Timestamp>)
Progress information. Subsequent messages from this worker will only contain timestamps greater or equal to an element of this frontier.
An empty antichain indicates the end.
Rows(Vec<(Row, Timestamp, Diff)>)
Rows that should be returned in order to the client.
Dropped
The TAIL dataflow was dropped before completing. Indicates the end.
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
This method tests for self
and other
values to be equal, and is used
by ==
. Read more
This method tests for !=
.
Auto Trait Implementations
impl RefUnwindSafe for TailResponse
impl Send for TailResponse
impl Sync for TailResponse
impl Unpin for TailResponse
impl UnwindSafe for TailResponse
Blanket Implementations
Mutably borrows from an owned value. Read more
Compare self to key
and return true
if they are equal.
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