Struct SqlitePool 

pub struct SqlitePool { /* private fields */ }

A bounded pool of plain OS threads shared by every database of one runtime process. The pool spawns threads lazily, up to its cap, only when no thread is free. Cloning shares the pool; it shuts down once the owner and every database handle have dropped their clones.

Implementations

impl SqlitePool

pub fn from_env(metrics: Option<Arc<dyn SqlitePoolMetrics>>) -> Self

Reads the thread cap from RIVETKIT_SQLITE_WORKER_THREADS.

pub fn new( max_threads: usize, metrics: Option<Arc<dyn SqlitePoolMetrics>>, ) -> Self

Starts no threads; the first database action spawns the first one.

pub fn page_budget(&self) -> &Arc<PageBudget>

The page budget every database on this pool shares.

pub fn request_allocator_trim(&self)

Threads spawned so far, never more than the cap. Returns freed native memory to the OS soon, on a pool thread, coalescing requests so trims run at most once per ALLOCATOR_TRIM_INTERVAL. Call after releasing a database.

pub fn live_threads(&self) -> usize

pub fn max_threads(&self) -> usize

Trait Implementations

impl Clone for SqlitePool

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.