dbconnpool

type Config struct {
	// DriverName specifies the name of the database driver to use (e.g., "sqlite").
	DriverName string

	// ReadOnly opens connections in read-only mode. When true, connection
	// creation is not serialized, allowing parallel preparation of statements.
	ReadOnly bool

	// Maximum number of connections the pool will create.
	MaxConnections int64

	// Minimum number of idle connections to maintain.
	MinIdleConnections int64

	// QueriesFunc is a function to instantiate a Queries object for a new connection.
	QueriesFunc func(db gallerydb.DBTX) *gallerydb.CustomQueries

	// MonitorInterval specifies how often the connection maintenance monitor should run.
	MonitorInterval time.Duration

	// HealthCheckThreshold is the minimum idle duration before a connection is
	// pinged on Get(). Connections idle for less than this are assumed healthy
	// and returned without a round-trip ping.
	// Default: 30s. Set to 0 to ping on every Get().
	HealthCheckThreshold time.Duration
}

type ConnectionError struct {
	Op  string // the operation that failed (e.g., "ping", "connect")
	Err error  // the underlying error
}

type ConnectionPool interface {
	// Get acquires a connection from the pool. Blocks if pool is at capacity.
	// Returns ErrPoolClosed if the pool has been closed.
	Get() (*CpConn, error)

	// Put returns a connection to the pool for reuse.
	// Safe to call with nil (no-op).
	Put(cpc *CpConn)

	// Close gracefully shuts down the pool, closing all connections.
	// Returns ErrPoolClosed if already closed.
	Close() error

	// DB returns the underlying *sql.DB for operations that need direct access
	// (e.g., migrations). Use sparingly.
	DB() *sql.DB

	// NumIdleConnections returns the current number of idle connections.
	NumIdleConnections() int

	// NumConnections returns the total number of connections (idle + in-use).
	NumConnections() int64
}

type CpConn struct {
	// Conn is the underlying database connection.
	Conn *sql.Conn

	// Queries holds the sqlc-generated query methods for this connection.
	Queries *gallerydb.CustomQueries
	// contains filtered or unexported fields
}

type DbSQLConnPool struct {
	// Config holds the pool's configuration.
	Config Config
	// contains filtered or unexported fields
}