database

Jul 28, 2025

Changes in this version

+ const ConnectionPoolPercentageMultiplier

+ const ConnectionPoolWarningThreshold

+ const DefaultPingTimeout

+ const MinArgsLength

+ var TickerDuration = 1 * time.Minute

+ type DB interface

+ Close func() error

+ GetDB func() *gorm.DB

+ MonitorConnectionPool func(ctx context.Context)

+ Ping func(ctx context.Context) error

+ type GormDB struct

+ func New(cfg *config.Config, appLogger logging.Logger) (*GormDB, error)

+ func NewWithDB(db *gorm.DB, appLogger logging.Logger) *GormDB

+ func (db *GormDB) Close() error

+ func (db *GormDB) GetDB() *gorm.DB

+ func (db *GormDB) MonitorConnectionPool(ctx context.Context)

+ func (db *GormDB) Ping(ctx context.Context) error

+ type GormLogWriter struct

+ func (w *GormLogWriter) Error(msg string, err error)

+ func (w *GormLogWriter) Printf(format string, args ...any)

+ func (w *GormLogWriter) Write(p []byte) (n int, err error)

May 23, 2025

Changes in this version

+ func NewDatabase(cfg *config.Config) (*sqlx.DB, error)

+ type Database struct

+ func NewDB(cfg *config.Config, logger logging.Logger) (*Database, error)

+ func (db *Database) Begin() (*sqlx.Tx, error)

+ func (db *Database) Close() error