Struct JournalState 

pub struct JournalState {
    pub journal: Journal,
    pub conn: Connection,
    /* private fields */
}

An open journal paired with its SQLite cache connection.

Create with JournalState::open or JournalState::rebuild, then pass references to crate::ops functions.

The vector store (if configured) is loaded lazily on the first call to JournalState::load_vector_store and cached for the lifetime of the state.

Fields

journal: Journal

conn: Connection

Implementations

impl JournalState

pub fn open(journal: Journal) -> Result<Self>

Open the cache for journal, creating it if it does not yet exist.

pub fn rebuild(journal: Journal) -> Result<Self>

Drop and recreate the cache from scratch, then return the new state.

pub fn sync(&self) -> Result<()>

Incrementally sync the cache with the current on-disk journal state.

pub fn cache_info(&self) -> Result<CacheInfo>

Return cache statistics (path, schema version, entry count, etc.).

pub fn load_vector_store(&self, config: &UserConfig) -> Result<()>

Initialize the vector store from the user config if not already done (sync).

Idempotent — if the vector store is already loaded this is a no-op. Returns an error if the configured backend fails to open (e.g. LanceDB directory is inaccessible).

See also load_vector_store_async for async callers (e.g. Dioxus GUI) where contention-free init is preferred.

pub async fn load_vector_store_async(&self, config: &UserConfig) -> Result<()>

Initialize the vector store from the user config if not already done (async).

Preferred over load_vector_store in async contexts; at most one initialization runs even under concurrent callers.

pub fn vector_store(&self) -> Option<&dyn VectorStore>

Borrow the vector store if it has been loaded and is configured.

Returns None if neither [load_vector_store] nor [load_vector_store_async] has been called yet, or if vector_db = "none" in the user config.

pub fn load_embedder(&self, config: &UserConfig) -> Result<()>

Initialize the embedder from the user config if not already done (sync).

For "fastembed" this loads the ONNX model from disk (slow on first call, instant on subsequent calls). REST providers are lightweight. Idempotent — if the embedder is already loaded this is a no-op.

See also load_embedder_async for async callers.

pub async fn load_embedder_async(&self, config: &UserConfig) -> Result<()>

Initialize the embedder from the user config if not already done (async).

Preferred over load_embedder in async contexts; at most one initialization runs even under concurrent callers.

pub fn embedder(&self) -> Option<&dyn Embedder>

Borrow the embedder if it has been loaded and an embedding provider is configured.

Returns None if load_embedder has not been called yet, or if no [cache.embedding] section exists in the user config.