dbresolver

Aug 14, 2023

Changes in this version

+ func ConnPoolToSqlDB(connPool gorm.ConnPool, db *gorm.DB) (*sql.DB, bool)

Dec 4, 2022

Changes in this version

+ func NewResolverModeLogger(l logger.Interface) logger.Interface

type Config

+ TraceResolverMode bool

+ type ResolverMode string

+ const ResolverModeReplica

+ const ResolverModeSource

+ type ResolverModeKey string

Apr 30, 2022

Changes in this version

+ func Use(str string) clause.Expression

+ type Config struct

+ Policy Policy

+ Replicas []gorm.Dialector

+ Sources []gorm.Dialector

+ type DBResolver struct

+ func Register(config Config, datas ...interface{}) *DBResolver

+ func (dr *DBResolver) Call(fc func(connPool gorm.ConnPool) error) error

+ func (dr *DBResolver) Initialize(db *gorm.DB) error

+ func (dr *DBResolver) Name() string

+ func (dr *DBResolver) Register(config Config, datas ...interface{}) *DBResolver

+ func (dr *DBResolver) SetConnMaxIdleTime(d time.Duration) *DBResolver

+ func (dr *DBResolver) SetConnMaxLifetime(d time.Duration) *DBResolver

+ func (dr *DBResolver) SetMaxIdleConns(n int) *DBResolver

+ func (dr *DBResolver) SetMaxOpenConns(n int) *DBResolver

+ type Operation string

+ const Read

+ const Write

+ func (op Operation) Build(clause.Builder)

+ func (op Operation) ModifyStatement(stmt *gorm.Statement)

+ type Policy interface

+ Resolve func([]gorm.ConnPool) gorm.ConnPool

+ type RandomPolicy struct

+ func (RandomPolicy) Resolve(connPools []gorm.ConnPool) gorm.ConnPool