Struct SpgConnectOptions 

pub struct SpgConnectOptions {
    pub path: Option<PathBuf>,
    pub log_settings: LogSettings,
    /* private fields */
}

Options for opening an SpgConnection.

v7.16.0 — every clone of an SpgConnectOptions shares the same underlying AsyncDatabase once the first connect() resolves. That’s the key to making sqlx::Pool<Spg> behave the way mailrs expects: pool.begin() and a separate pool.acquire() on the same pool reach the same in-process engine, so transaction visibility works.

Fields

path: Option<PathBuf>

Where to open the database. None → in-memory.

log_settings: LogSettings

sqlx log settings — adapter-level no-op for v7.16.0 but preserved so the log_statements / log_slow_statements builders compile.

Implementations

impl SpgConnectOptions

pub fn in_memory() -> Self

Construct an in-memory database options handle.

pub fn file(path: impl Into<PathBuf>) -> Self

Construct a file-backed options handle.

pub fn clear_shared(&mut self)

v7.37.5 (mailrs crash-recovery Ask 2) — force the shared OnceCell<AsyncDatabase> back to empty so the next connect() re-opens the catalog instead of handing back a stale cached handle. Pairs with spg_embedded::Database::force_unlock: when the operator asserts “no one owns this catalog; nuke the lock”, any previously-shared AsyncDatabase that still holds the engine in this process must also be discarded so the new boot’s connect_with opens fresh.

Replaces the Arc<OnceCell<_>> with a brand-new empty cell; existing clones of these options that already grabbed an Arc clone to the prior cell keep using it (they’re the callers that opted in to the shared handle); this method only resets THIS handle. The typical mailrs shape — one SpgConnectOptions per pool, recycled at force_unlock time — is correctly served.

Trait Implementations

impl Clone for SpgConnectOptions

fn clone(&self) -> SpgConnectOptions

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl ConnectOptions for SpgConnectOptions

type Connection = SpgConnection

fn from_url(url: &Url) -> Result<Self, Error>

Parse the ConnectOptions from a URL.

fn connect(&self) -> BoxFuture<'_, Result<SpgConnection, Error>>

Establish a new database connection with the options specified by self.

fn log_statements(self, level: LevelFilter) -> Self

Log executed statements with the specified level

fn log_slow_statements(self, level: LevelFilter, duration: Duration) -> Self

Log executed statements with a duration above the specified duration at the specified level.

fn to_url_lossy(&self) -> Url

Get a connection URL that may be used to connect to the same database as this ConnectOptions.

fn disable_statement_logging(self) -> Self

Entirely disables statement logging (both slow and regular).

impl Debug for SpgConnectOptions

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for SpgConnectOptions

fn default() -> Self

Returns the “default value” for a type.

impl FromStr for SpgConnectOptions

type Err = Error

The associated error which can be returned from parsing.

fn from_str(s: &str) -> Result<Self, Error>

Parses a string s to return a value of this type.