Struct UmaDB 

pub struct UmaDB { /* private fields */ }

EventStore implementing the DCBEventStoreSync interface

Implementations

impl UmaDB

pub fn new<P: AsRef<Path>>(path: P) -> DCBResult<Self>

Create a new EventStore at the given directory or file path. If a directory path is provided, a file named “uma.db” will be used inside it.

pub fn from_arc(mvcc: Arc<Mvcc>) -> Self

pub fn append_batch( &self, items: Vec<(Vec<DCBEvent>, Option<DCBAppendCondition>)>, force_sequential_read: bool, ) -> DCBResult<Vec<DCBResult<u64>>>

Appends a batch of (events, condition) using a single writer/transaction. For each item, behaves like append():

• If condition is Some and matches any events (considering uncommitted writes), returns Err(IntegrityError) for that item and continues.
• If events is empty, returns Ok(0) for that item and continues.
• Otherwise performs unconditional append and records Ok(last_position) for that item.

At the end, commits the writer once. If commit fails, returns the commit error and discards per-item results.

Trait Implementations

impl DCBEventStoreSync for UmaDB

fn read( &self, query: Option<DCBQuery>, start: Option<u64>, backwards: bool, limit: Option<u32>, _subscribe: bool, ) -> DCBResult<Box<dyn DCBReadResponseSync + 'static>>

Reads events from the store based on the provided query and constraints

fn head(&self) -> DCBResult<Option<u64>>

Returns the current head position of the event store, or None if empty

fn append( &self, events: Vec<DCBEvent>, condition: Option<DCBAppendCondition>, ) -> DCBResult<u64>

Appends given events to the event store, unless the condition fails

fn read_with_head( &self, query: Option<DCBQuery>, start: Option<u64>, backwards: bool, limit: Option<u32>, ) -> Result<(Vec<DCBSequencedEvent>, Option<u64>), DCBError>

Reads events from the store and returns them as a tuple of (Vec, Option)