Versions in this module Expand all Collapse all v1 v1.2.3 Sep 4, 2025 Changes in this version + func CheckHealth() error + func GetDB() (*sql.DB, error) + func GetDialect() string + func IsConnected() bool + type DBMysqlClient struct + func NewMysqlClient() *DBMysqlClient + func (m *DBMysqlClient) CleanupTasks() error + func (m *DBMysqlClient) StartupTasks() error + type PrometheusConfig struct + Labels map[string]string + Namespace string + Subsystem string + type PrometheusMetrics struct + func NewPrometheusMetrics(config *PrometheusConfig) *PrometheusMetrics + func (m *PrometheusMetrics) GetGatherer() prometheus.Gatherer + func (m *PrometheusMetrics) IncConnectAttempt(config *conf.Mysql) + func (m *PrometheusMetrics) IncConnectFailure(config *conf.Mysql) + func (m *PrometheusMetrics) IncConnectRetry(config *conf.Mysql) + func (m *PrometheusMetrics) IncConnectSuccess(config *conf.Mysql) + func (m *PrometheusMetrics) RecordHealthCheck(success bool, config *conf.Mysql) + func (m *PrometheusMetrics) RecordQuery(op string, dur time.Duration, err error, threshold time.Duration, ...) + func (m *PrometheusMetrics) RecordTx(dur time.Duration, committed bool, config *conf.Mysql) + func (m *PrometheusMetrics) UpdateMetrics(stats *base.ConnectionPoolStats, config *conf.Mysql)
Go to main page