Struct dataflow::source::SourceTransaction

pub struct SourceTransaction<'a> {
    timestamp: RwLockReadGuard<'a, Timestamp>,
    sender: &'a Sender<Event<Option<Timestamp>, Result<(Row, Timestamp, Diff), SourceError>>>,
}

An active transaction at a particular point in time. An instance of this struct is provided to a source when calling start_tx() on its timestamper. This has the effect of freezing the timestamper clock while the data for the transaction is sent.

The transaction is automatically committed on Drop at which point the timestamper will continue ticking its internal clock.

Fields

timestamp: RwLockReadGuard<'a, Timestamp>

sender: &'a Sender<Event<Option<Timestamp>, Result<(Row, Timestamp, Diff), SourceError>>>

Implementations

impl SourceTransaction<'_>

pub async fn insert(&self, row: Row) -> Result<()>

Record an insertion of a row in the current transaction

pub async fn delete(&self, row: Row) -> Result<()>

Record a deletion of a row in the current transaction