Struct mz_timely_util::builder_async::Disconnected
source · pub struct Disconnected;
Expand description
A marker type representing a disconnected input.
Trait Implementations§
source§impl<T: Timestamp> InputConnection<T> for Disconnected
impl<T: Timestamp> InputConnection<T> for Disconnected
§type Capability = T
type Capability = T
The capability type associated with this connection behavior.
source§fn describe(&self, outputs: usize) -> Vec<Antichain<T::Summary>>
fn describe(&self, outputs: usize) -> Vec<Antichain<T::Summary>>
Generates a summary description of the connection behavior given the number of outputs.
source§fn accept(&self, input_cap: InputCapability<T>) -> Self::Capability
fn accept(&self, input_cap: InputCapability<T>) -> Self::Capability
Accepts an input capability.
Auto Trait Implementations§
impl Freeze for Disconnected
impl RefUnwindSafe for Disconnected
impl Send for Disconnected
impl Sync for Disconnected
impl Unpin for Disconnected
impl UnwindSafe for Disconnected
Blanket Implementations§
source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
source§impl<R, O, T> CopyOnto<ConsecutiveOffsetPairs<R, O>> for T
impl<R, O, T> CopyOnto<ConsecutiveOffsetPairs<R, O>> for T
source§fn copy_onto(
self,
target: &mut ConsecutiveOffsetPairs<R, O>
) -> <ConsecutiveOffsetPairs<R, O> as Region>::Index
fn copy_onto( self, target: &mut ConsecutiveOffsetPairs<R, O> ) -> <ConsecutiveOffsetPairs<R, O> as Region>::Index
Copy self into the target container, returning an index that allows to
look up the corresponding read item.
source§impl<T> FutureExt for T
impl<T> FutureExt for T
source§fn with_context(self, otel_cx: Context) -> WithContext<Self>
fn with_context(self, otel_cx: Context) -> WithContext<Self>
source§fn with_current_context(self) -> WithContext<Self>
fn with_current_context(self) -> WithContext<Self>
source§impl<T> Instrument for T
impl<T> Instrument for T
source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
source§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
source§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message
T
in a tonic::Request