pub enum TxnMsg {
Begin(TxnId),
Data(TxnId, StreamChunk),
End(TxnId),
Rollback(TxnId),
}
Variants§
Implementations§
source§impl TxnMsg
impl TxnMsg
sourcepub fn as_begin_mut(&mut self) -> Option<&mut TxnId>
pub fn as_begin_mut(&mut self) -> Option<&mut TxnId>
Optionally returns mutable references to the inner fields if this is a TxnMsg::Begin
, otherwise None
sourcepub fn as_begin(&self) -> Option<&TxnId>
pub fn as_begin(&self) -> Option<&TxnId>
Optionally returns references to the inner fields if this is a TxnMsg::Begin
, otherwise None
sourcepub fn into_begin(self) -> Result<TxnId, Self>
pub fn into_begin(self) -> Result<TxnId, Self>
Returns the inner fields if this is a TxnMsg::Begin
, otherwise returns back the enum in the Err
case of the result
sourcepub fn as_data_mut(&mut self) -> Option<(&mut TxnId, &mut StreamChunk)>
pub fn as_data_mut(&mut self) -> Option<(&mut TxnId, &mut StreamChunk)>
Optionally returns mutable references to the inner fields if this is a TxnMsg::Data
, otherwise None
sourcepub fn as_data(&self) -> Option<(&TxnId, &StreamChunk)>
pub fn as_data(&self) -> Option<(&TxnId, &StreamChunk)>
Optionally returns references to the inner fields if this is a TxnMsg::Data
, otherwise None
sourcepub fn into_data(self) -> Result<(TxnId, StreamChunk), Self>
pub fn into_data(self) -> Result<(TxnId, StreamChunk), Self>
Returns the inner fields if this is a TxnMsg::Data
, otherwise returns back the enum in the Err
case of the result
sourcepub fn as_end_mut(&mut self) -> Option<&mut TxnId>
pub fn as_end_mut(&mut self) -> Option<&mut TxnId>
Optionally returns mutable references to the inner fields if this is a TxnMsg::End
, otherwise None
sourcepub fn as_end(&self) -> Option<&TxnId>
pub fn as_end(&self) -> Option<&TxnId>
Optionally returns references to the inner fields if this is a TxnMsg::End
, otherwise None
sourcepub fn into_end(self) -> Result<TxnId, Self>
pub fn into_end(self) -> Result<TxnId, Self>
Returns the inner fields if this is a TxnMsg::End
, otherwise returns back the enum in the Err
case of the result
sourcepub fn is_rollback(&self) -> bool
pub fn is_rollback(&self) -> bool
Returns true if this is a TxnMsg::Rollback
, otherwise false
sourcepub fn as_rollback_mut(&mut self) -> Option<&mut TxnId>
pub fn as_rollback_mut(&mut self) -> Option<&mut TxnId>
Optionally returns mutable references to the inner fields if this is a TxnMsg::Rollback
, otherwise None
sourcepub fn as_rollback(&self) -> Option<&TxnId>
pub fn as_rollback(&self) -> Option<&TxnId>
Optionally returns references to the inner fields if this is a TxnMsg::Rollback
, otherwise None
sourcepub fn into_rollback(self) -> Result<TxnId, Self>
pub fn into_rollback(self) -> Result<TxnId, Self>
Returns the inner fields if this is a TxnMsg::Rollback
, otherwise returns back the enum in the Err
case of the result
source§impl TxnMsg
impl TxnMsg
pub fn txn_id(&self) -> TxnId
pub fn as_stream_chunk(&self) -> Option<&StreamChunk>
Trait Implementations§
Auto Trait Implementations§
impl Freeze for TxnMsg
impl RefUnwindSafe for TxnMsg
impl Send for TxnMsg
impl Sync for TxnMsg
impl Unpin for TxnMsg
impl UnwindSafe for TxnMsg
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
§impl<T> FutureExt for T
impl<T> FutureExt for T
§fn with_context(self, otel_cx: Context) -> WithContext<Self>
fn with_context(self, otel_cx: Context) -> WithContext<Self>
§fn with_current_context(self) -> WithContext<Self>
fn with_current_context(self) -> WithContext<Self>
§impl<T> Instrument for T
impl<T> Instrument for T
§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<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> IntoEither for T
impl<T> IntoEither for T
source§fn into_either(self, into_left: bool) -> Either<Self, Self>
fn into_either(self, into_left: bool) -> Either<Self, Self>
self
into a Left
variant of Either<Self, Self>
if into_left
is true
.
Converts self
into a Right
variant of Either<Self, Self>
otherwise. Read moresource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
self
into a Left
variant of Either<Self, Self>
if into_left(&self)
returns true
.
Converts self
into a Right
variant of Either<Self, Self>
otherwise. Read moresource§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>
T
in a tonic::Request
§impl<T> IntoResult<T> for T
impl<T> IntoResult<T> for T
type Err = Infallible
fn into_result(self) -> Result<T, <T as IntoResult<T>>::Err>
source§impl<M> MetricVecRelabelExt for M
impl<M> MetricVecRelabelExt for M
source§fn relabel(
self,
metric_level: MetricLevel,
relabel_threshold: MetricLevel,
) -> RelabeledMetricVec<M>
fn relabel( self, metric_level: MetricLevel, relabel_threshold: MetricLevel, ) -> RelabeledMetricVec<M>
RelabeledMetricVec::with_metric_level
.source§fn relabel_n(
self,
metric_level: MetricLevel,
relabel_threshold: MetricLevel,
relabel_num: usize,
) -> RelabeledMetricVec<M>
fn relabel_n( self, metric_level: MetricLevel, relabel_threshold: MetricLevel, relabel_num: usize, ) -> RelabeledMetricVec<M>
RelabeledMetricVec::with_metric_level_relabel_n
.source§fn relabel_debug_1(
self,
relabel_threshold: MetricLevel,
) -> RelabeledMetricVec<M>
fn relabel_debug_1( self, relabel_threshold: MetricLevel, ) -> RelabeledMetricVec<M>
RelabeledMetricVec::with_metric_level_relabel_n
with metric_level
set to
MetricLevel::Debug
and relabel_num
set to 1.