Enum mz_adapter::coord::PendingReadTxn
source · pub enum PendingReadTxn {
Read {
txn: PendingTxn,
timestamp_context: TimestampContext<Timestamp>,
},
ReadThenWrite {
tx: Sender<()>,
timestamp: (Timestamp, Timeline),
},
}
Expand description
A pending read transaction waiting to be linearized.
Variants§
Read
Fields
§
txn: PendingTxn
The inner transaction.
§
timestamp_context: TimestampContext<Timestamp>
The timestamp context of the transaction.
ReadThenWrite
Implementations§
source§impl PendingReadTxn
impl PendingReadTxn
sourcepub fn timestamp_context(&self) -> TimestampContext<Timestamp>
pub fn timestamp_context(&self) -> TimestampContext<Timestamp>
Return the timestamp context of the pending read transaction.
sourcepub fn finish(
self
) -> Option<(ExecuteContext, Result<ExecuteResponse, AdapterError>)>
pub fn finish( self ) -> Option<(ExecuteContext, Result<ExecuteResponse, AdapterError>)>
Alert the client that the read has been linearized.
If it is necessary to finalize an execute, return the state necessary to do so (execution context and result)
Trait Implementations§
Auto Trait Implementations§
impl !RefUnwindSafe for PendingReadTxn
impl Send for PendingReadTxn
impl Sync for PendingReadTxn
impl Unpin for PendingReadTxn
impl !UnwindSafe for PendingReadTxn
Blanket Implementations§
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
source§impl<T> Pointable for T
impl<T> Pointable for T
source§impl<P, R> ProtoType<R> for Pwhere
R: RustType<P>,
impl<P, R> ProtoType<R> for Pwhere R: RustType<P>,
source§fn into_rust(self) -> Result<R, TryFromProtoError>
fn into_rust(self) -> Result<R, TryFromProtoError>
See
RustType::from_proto
.source§fn from_rust(rust: &R) -> P
fn from_rust(rust: &R) -> P
See
RustType::into_proto
.