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 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 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 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

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.