database

package

v0.0.0-...-cd49aae Latest Latest Go to latest Published: Jul 29, 2024 License: MIT Imports: 12 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type DBManager struct {
	DSN    string
	DBs    []string
	Tables map[string][]string
	DbPool *sql.DB
}

func NewDBManager(mysqlConfig config.MySQLConfig) *DBManager

NewDBManager initializes DBManager with the provided MySQL configuration and creates a new connection pool.

func (dbm *DBManager) Conn(ctx context.Context) (*sql.Conn, error)

func (dbm *DBManager) InitializeDatabases(cfg config.MainConfig, sysLog syslogwrapper.SyslogWrapperInterface, apiPlugin api_plugins.APIPlugin)

func (dbm *DBManager) PingIdleConnections(sysLog syslogwrapper.SyslogWrapperInterface)

PingIdleConnections pings all idle connections in the pool to keep them healthy

type DBManagerInterface interface {
	Conn(ctx context.Context) (*sql.Conn, error)
}