Struct pravega_client::event::transactional_writer::Transaction

pub struct Transaction { /* private fields */ }

Pravega Transaction support.

It can be used to write, commit and abort a Pravega Transaction.

Implementations

impl Transaction

pub fn txn_id(&self) -> TxId

get the transaction id.

pub fn stream(&self) -> ScopedStream

get the stream that this transaction is based on.

pub async fn write_event( &mut self, routing_key: Option<String>, event: Vec<u8> ) -> Result<(), TransactionError>

write_event accepts a vec of bytes as the input event and an optional routing key which is used to determine which segment to write to. It calls the corresponding transactional event segment writer to write the data to the server.

pub async fn commit( &mut self, timestamp: Timestamp ) -> Result<(), TransactionError>

commit accepts a timestamp and will send a commit request to Pravega controller.

pub async fn abort(&mut self) -> Result<(), TransactionError>

abort will send abort request to Pravega controller.

pub async fn check_status(&self) -> Result<TransactionStatus, TransactionError>

check the current Transaction status by sending request to Pravega controller.

Trait Implementations

impl Drop for Transaction

fn drop(&mut self)

Executes the destructor for this type.