Struct LmdbCanonicalStore 

pub struct LmdbCanonicalStore { /* private fields */ }

LMDB-backed canonical store

State is stored in LMDB for transactional integrity. Events are stored in a file-based event log for better performance.

Implementations

impl LmdbCanonicalStore

pub fn event_log(&self) -> &Arc<FileEventLog>

Get reference to the file-based event log

This allows direct access to event storage for advanced use cases.

Trait Implementations

impl CanonicalStore for LmdbCanonicalStore

type Txn<'a> = LmdbWriteTxn<'a>

fn open(cfg: CanonicalConfig) -> Result<LmdbCanonicalStore, AzothError>

Open a canonical store

fn close(&self) -> Result<(), AzothError>

Close the store

fn read_txn( &self, ) -> Result<<LmdbCanonicalStore as CanonicalStore>::Txn<'_>, AzothError>

Begin a read-only transaction

fn write_txn( &self, ) -> Result<<LmdbCanonicalStore as CanonicalStore>::Txn<'_>, AzothError>

Begin a write transaction

fn iter_events( &self, from: u64, to: Option<u64>, ) -> Result<Box<dyn EventIter>, AzothError>

Iterate events in a range

fn seal(&self) -> Result<u64, AzothError>

Seal the store at the current event ID

fn lock_manager(&self) -> &LockManager

Get the lock manager for stripe locking

fn pause_ingestion(&self) -> Result<(), AzothError>

Pause ingestion (stop accepting new writes)

fn resume_ingestion(&self) -> Result<(), AzothError>

Resume ingestion (allow new writes)

fn is_paused(&self) -> bool

Check if ingestion is paused

fn backup_to(&self, dir: &Path) -> Result<BackupInfo, AzothError>

Create a backup

fn restore_from( dir: &Path, cfg: CanonicalConfig, ) -> Result<LmdbCanonicalStore, AzothError>

Restore from a backup

fn meta(&self) -> Result<CanonicalMeta, AzothError>

Get store metadata