Struct Database 

pub struct Database { /* private fields */ }

Thin wrapper around a SQLite connection pool.

Implementations

impl Database

pub async fn open(db_path: &Path) -> Result<Self, DbError>

Opens the SQLite database and runs embedded migrations.

Uses up to DB_POOL_MAX_CONNECTIONS pooled connections so UI reads can stay responsive without oversizing the SQLite pool beyond what WAL can use effectively. Applies a short busy timeout so bursty reducer writes wait briefly for the single SQLite writer instead of failing immediately with SQLITE_BUSY.

Errors

Returns an error if the directory cannot be created, the database cannot be opened, or migrations fail.

pub async fn open_with_timestamp_source( db_path: &Path, timestamp_source: Arc<dyn TimestampSource>, ) -> Result<Self, DbError>

Opens the SQLite database with an injected persistence timestamp source.

Errors

Returns an error if the directory cannot be created, the database cannot be opened, or migrations fail.

pub async fn open_in_memory() -> Result<Self, DbError>

Opens an in-memory SQLite database and runs migrations.

This is primarily used by tests and any ephemeral workflows that need an isolated database instance while keeping the same durability and foreign-key settings as the on-disk database. Applies the same short busy timeout as the on-disk configuration so tests exercise the same writer wait policy.

Errors

Returns an error if the database connection or migrations fail.

pub async fn open_in_memory_with_timestamp_source( timestamp_source: Arc<dyn TimestampSource>, ) -> Result<Self, DbError>

Opens an in-memory SQLite database with an injected timestamp source.

Errors

Returns an error if the database connection or migrations fail.

pub fn pool(&self) -> &SqlitePool

Returns the shared SQLite connection pool for lower-level query access.

Methods from Deref<Target = AppRepositories>

pub fn activity(&self) -> &dyn ActivityRepository

Returns the activity-event repository.

pub fn operations(&self) -> &dyn OperationRepository

Returns the session-operation repository.

pub fn orchestrations(&self) -> &dyn OrchestrationRepository

Returns the orchestration repository.

pub fn orchestration_repository(&self) -> Arc<dyn OrchestrationRepository>

Returns a cloneable orchestration repository for background reconciliation.

pub fn projects(&self) -> &dyn ProjectRepository

Returns the project repository.

pub fn reviews(&self) -> &dyn ReviewRepository

Returns the session review-request repository.

pub fn sessions(&self) -> &dyn SessionRepository

Returns the session repository.

pub fn settings(&self) -> &dyn SettingRepository

Returns the settings repository.

pub fn usage(&self) -> &dyn UsageRepository

Returns the per-session usage repository.

Trait Implementations

impl Clone for Database

fn clone(&self) -> Database

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Deref for Database

type Target = AppRepositories

The resulting type after dereferencing.

fn deref(&self) -> &Self::Target

Dereferences the value.

impl From<Database> for AppRepositories

fn from(database: Database) -> Self

Converts to this type from the input type.