Struct AppState 

pub struct AppState {
    pub(crate) db_path: String,
    pub(crate) auth: Auth,
    pub(crate) scheduler_status: Option<Arc<Mutex<SchedulerStatus>>>,
    pub(crate) write_lock: Mutex<()>,
    pub(crate) cache: RwLock<Option<Arc<Model>>>,
    pub(crate) loaded_tx: Mutex<Option<i64>>,
}

Fields

db_path: String

auth: Auth

scheduler_status: Option<Arc<Mutex<SchedulerStatus>>>

None when the scheduler is disabled (the default; IMPROV_SCHEDULER=1 enables).

write_lock: Mutex<()>

Held across every load-modify-save of the store (API writes and the scheduler), so concurrent writers cannot lose each other’s updates (S12).

cache: RwLock<Option<Arc<Model>>>

The loaded model, None until first read or after invalidation (P4).

loaded_tx: Mutex<Option<i64>>

The store high-water cache was loaded/saved at; a save from a stale cache (another process wrote since) is refused with 409.

Implementations

impl AppState

pub fn new( db_path: String, auth: Auth, scheduler_status: Option<Arc<Mutex<SchedulerStatus>>>, ) -> Self