Struct FrankenConnectionManager 

pub struct FrankenConnectionManager { /* private fields */ }

Multi-connection manager for frankensqlite.

Provides:

• A pool of pre-opened reader connections (round-robin, Mutex-protected)
• Controlled creation of writer connections with token-based limits
• RAII guards that auto-rollback uncommitted transactions on drop

Thread-safe: reader connections are wrapped in Mutex (FrankenConnection is !Sync). Writer connections are created per-request (each thread gets its own).

Implementations

impl FrankenConnectionManager

pub fn new( db_path: impl Into<PathBuf>, config: ConnectionManagerConfig, ) -> Result<Self>

Create a new connection manager.

Opens config.reader_count reader connections immediately. Writer connections are created on demand (up to config.max_writers).

pub fn reader(&self) -> MutexGuard<'_, SendFrankenConnection>

Get a reader connection (round-robin from the pool).

Returns a mutex guard wrapping the connection. The guard prevents concurrent access to the same connection (FrankenConnection is !Sync).

pub fn writer(&self) -> Result<WriterGuard<'_>>

Acquire a writer connection.

Opens a new frankensqlite connection with full config (no migration). Blocks if max_writers connections are already in use. The returned WriterGuard auto-rolls back on drop.

pub fn concurrent_writer(&self) -> Result<WriterGuard<'_>>

Acquire a concurrent writer connection (BEGIN CONCURRENT via MVCC).

Similar to [writer] but tuned for the parallel indexer write pool. Uses reduced cache size and is designed for short-lived batch inserts.

pub fn db_path(&self) -> &Path

Database path managed by this pool.

pub fn reader_count(&self) -> usize

Number of reader connections in the pool.

pub fn max_writers(&self) -> usize

Maximum concurrent writers allowed.

Trait Implementations

impl Drop for FrankenConnectionManager

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.

impl Send for FrankenConnectionManager

impl Sync for FrankenConnectionManager