app

Mar 6, 2026

Changes in this version

+ var BaseConfig config.BaseConfig

+ var Config any = new(config.BaseConfig)

+ var DB *gorm.DB

+ var DBList map[string]*gorm.DB

+ var DBResolver *gorm.DB

+ var ES *elasticsearch.TypedClient

+ var Env string

+ var Etcd *clientv3.Client

+ var Logger *logrus.Logger

+ var RabbitMQProducerList sync.Map

+ var Redis redis.UniversalClient

+ var RedisList map[string]redis.UniversalClient

+ func CheckPoolHealth() map[string]HealthStatus

+ func CloseAllDB() error

+ func GetDbByName(dbname string) (*gorm.DB, error)

+ func GetRedisByName(name string) (redis.UniversalClient, error)

+ func IsAllHealthy() bool

+ func SendRabbitMqMsg(queueName string, exchangeName string, exchangeType string, routingKey string, ...) error

+ func SendRabbitMqMsgBatch(queueName string, exchangeName string, exchangeType string, routingKey string, ...) error

+ func SendRabbitMqMsgBatchWithContext(ctx context.Context, queueName string, exchangeName string, ...) error

+ func SendRabbitMqMsgWithConfirm(queueName string, exchangeName string, exchangeType string, routingKey string, ...) error

+ type DBInstanceStats struct

+ Idle int

+ InUse int

+ MaxIdleClosed int64

+ MaxLifetimeClosed int64

+ MaxOpenConns int

+ OpenConns int

+ WaitCount int64

+ WaitDurationMs int64

+ type HealthStatus struct

+ Error string

+ Healthy bool

+ Stats map[string]int

+ type PoolStats struct

+ DBIdle int

+ DBInUse int

+ DBListStats map[string]*DBInstanceStats

+ DBMaxIdleClosed int64

+ DBMaxLifetimeClosed int64

+ DBMaxOpenConns int

+ DBOpenConns int

+ DBResolverStats *DBInstanceStats

+ DBWaitCount int64

+ DBWaitDurationMs int64

+ RedisActiveConns int

+ RedisIdleConns int

+ RedisListStats map[string]*RedisInstanceStats

+ RedisPoolSize int

+ func GetPoolStats() *PoolStats

+ type RedisInstanceStats struct

+ ActiveConns int

+ IdleConns int

+ PoolSize int