Struct SimpleProjectionTxn 

pub struct SimpleProjectionTxn<'a> { /* private fields */ }

Implementations

impl<'a> SimpleProjectionTxn<'a>

pub fn new(conn: MutexGuard<'a, Connection>) -> Result<Self>

Trait Implementations

impl<'a> Drop for SimpleProjectionTxn<'a>

fn drop(&mut self)

Executes the destructor for this type.

impl<'a> ProjectionTxn for SimpleProjectionTxn<'a>

fn apply_event(&mut self, _id: EventId, _bytes: &[u8]) -> Result<()>

Apply a single event to the projection

fn commit(self: Box<Self>, new_cursor: EventId) -> Result<()>

Commit transaction and update cursor

fn rollback(self: Box<Self>)

Rollback transaction

fn apply_batch(&mut self, events: &[(u64, Vec<u8>)]) -> Result<(), AzothError>

Apply a batch of events to the projection