Struct mz_compute::sink::tail::TailProtocol
source · [−]struct TailProtocol {
pub sink_id: GlobalId,
pub tail_response_buffer: Option<Rc<RefCell<Vec<(GlobalId, TailResponse)>>>>,
pub prev_upper: Antichain<Timestamp>,
}
Expand description
A type that guides the transmission of rows back to the coordinator.
A protocol instance may send
rows indefinitely, and is consumed by complete
,
which is used only to indicate the end of a stream. The Drop
implementation
otherwise sends an indication that the protocol has finished without completion.
Fields
sink_id: GlobalId
tail_response_buffer: Option<Rc<RefCell<Vec<(GlobalId, TailResponse)>>>>
prev_upper: Antichain<Timestamp>
Implementations
sourceimpl TailProtocol
impl TailProtocol
Trait Implementations
Auto Trait Implementations
impl !RefUnwindSafe for TailProtocol
impl !Send for TailProtocol
impl !Sync for TailProtocol
impl Unpin for TailProtocol
impl !UnwindSafe for TailProtocol
Blanket Implementations
sourceimpl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
const: unstable · sourcefn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
sourceimpl<T> FutureExt for T
impl<T> FutureExt for T
sourcefn with_context(self, otel_cx: Context) -> WithContext<Self>
fn with_context(self, otel_cx: Context) -> WithContext<Self>
sourcefn with_current_context(self) -> WithContext<Self>
fn with_current_context(self) -> WithContext<Self>
sourceimpl<T> Instrument for T
impl<T> Instrument for T
sourcefn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
sourcefn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
sourceimpl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
sourcefn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message
T
in a tonic::Request
sourceimpl<T> Pointable for T
impl<T> Pointable for T
sourceimpl<P, R> ProtoType<R> for Pwhere
R: RustType<P>,
impl<P, R> ProtoType<R> for Pwhere
R: RustType<P>,
sourcefn into_rust(self) -> Result<R, TryFromProtoError>
fn into_rust(self) -> Result<R, TryFromProtoError>
See
RustType::from_proto
.sourcefn from_rust(rust: &R) -> P
fn from_rust(rust: &R) -> P
See
RustType::into_proto
.