Enum TxnMsg 

pub enum TxnMsg {
    Begin(TxnId),
    Data(TxnId, StreamChunk),
    End(TxnId, Option<Sender<Epoch>>),
    Rollback(TxnId),
}

Variants

Begin(TxnId)

Data(TxnId, StreamChunk)

End(TxnId, Option<Sender<Epoch>>)

Rollback(TxnId)

Implementations

impl TxnMsg

pub fn is_begin(&self) -> bool

Returns true if this is a TxnMsg::Begin, otherwise false

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

pub fn as_begin(&self) -> Option<&TxnId>

Optionally returns references to the inner fields if this is a TxnMsg::Begin, otherwise None

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

pub unsafe fn into_begin_unchecked(self) -> TxnId

Unchecked return of the inner fields of TxnMsg::Begin.

Safety

Results in undefined behavior when it is the incorrect variant.

pub unsafe fn as_begin_unchecked(&self) -> &TxnId

Unchecked reference of the inner fields of TxnMsg::Begin.

Safety

Results in undefined behavior when it is the incorrect variant.

pub unsafe fn as_begin_mut_unchecked(&mut self) -> &mut TxnId

Unchecked mutable reference of the inner fields of TxnMsg::Begin.

Safety

Results in undefined behavior when it is the incorrect variant.

pub fn is_data(&self) -> bool

Returns true if this is a TxnMsg::Data, otherwise false

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

pub fn as_data(&self) -> Option<(&TxnId, &StreamChunk)>

Optionally returns references to the inner fields if this is a TxnMsg::Data, otherwise None

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

pub unsafe fn into_data_unchecked(self) -> (TxnId, StreamChunk)

Unchecked return of the inner fields of TxnMsg::Data.

Safety

Results in undefined behavior when it is the incorrect variant.

pub unsafe fn as_data_unchecked(&self) -> (&TxnId, &StreamChunk)

Unchecked reference of the inner fields of TxnMsg::Data.

Safety

Results in undefined behavior when it is the incorrect variant.

pub unsafe fn as_data_mut_unchecked(&mut self) -> (&mut TxnId, &mut StreamChunk)

Unchecked mutable reference of the inner fields of TxnMsg::Data.

Safety

Results in undefined behavior when it is the incorrect variant.

pub fn is_end(&self) -> bool

Returns true if this is a TxnMsg::End, otherwise false

pub fn as_end_mut(&mut self) -> Option<(&mut TxnId, &mut Option<Sender<Epoch>>)>

Optionally returns mutable references to the inner fields if this is a TxnMsg::End, otherwise None

pub fn as_end(&self) -> Option<(&TxnId, &Option<Sender<Epoch>>)>

Optionally returns references to the inner fields if this is a TxnMsg::End, otherwise None

pub fn into_end(self) -> Result<(TxnId, Option<Sender<Epoch>>), Self>

Returns the inner fields if this is a TxnMsg::End, otherwise returns back the enum in the Err case of the result

pub unsafe fn into_end_unchecked(self) -> (TxnId, Option<Sender<Epoch>>)

Unchecked return of the inner fields of TxnMsg::End.

Safety

Results in undefined behavior when it is the incorrect variant.

pub unsafe fn as_end_unchecked(&self) -> (&TxnId, &Option<Sender<Epoch>>)

Unchecked reference of the inner fields of TxnMsg::End.

Safety

Results in undefined behavior when it is the incorrect variant.

pub unsafe fn as_end_mut_unchecked( &mut self, ) -> (&mut TxnId, &mut Option<Sender<Epoch>>)

Unchecked mutable reference of the inner fields of TxnMsg::End.

Safety

Results in undefined behavior when it is the incorrect variant.

pub fn is_rollback(&self) -> bool

Returns true if this is a TxnMsg::Rollback, otherwise false

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

pub fn as_rollback(&self) -> Option<&TxnId>

Optionally returns references to the inner fields if this is a TxnMsg::Rollback, otherwise None

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

pub unsafe fn into_rollback_unchecked(self) -> TxnId

Unchecked return of the inner fields of TxnMsg::Rollback.

Safety

Results in undefined behavior when it is the incorrect variant.

pub unsafe fn as_rollback_unchecked(&self) -> &TxnId

Unchecked reference of the inner fields of TxnMsg::Rollback.

Safety

Results in undefined behavior when it is the incorrect variant.

pub unsafe fn as_rollback_mut_unchecked(&mut self) -> &mut TxnId

Unchecked mutable reference of the inner fields of TxnMsg::Rollback.

Safety

Results in undefined behavior when it is the incorrect variant.

impl TxnMsg

pub fn txn_id(&self) -> TxnId

pub fn as_stream_chunk(&self) -> Option<&StreamChunk>

Trait Implementations

impl Debug for TxnMsg

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.