components

Apr 16, 2025

Changes in this version

+ func GetClickHouseGORMDB(name string) *gorm.DB

+ func GetDefaultClickHouseGORM() *gorm.DB

type ClickHouseConfig

+ DSN string

+ type ClickHouseGORMComponent struct

+ var DefaultClickHouseGORM *ClickHouseGORMComponent

+ func GetClickHouseGORMComponent(name string) *ClickHouseGORMComponent

+ func NewClickHouseGORMComponent(name string, config *ClickHouseGORMConfig, isDefault bool) *ClickHouseGORMComponent

+ func (c *ClickHouseGORMComponent) DB() *gorm.DB

+ func (c *ClickHouseGORMComponent) Start(ctx context.Context) error

+ func (c *ClickHouseGORMComponent) Stop(ctx context.Context) error

+ type ClickHouseGORMConfig struct

+ ConnMaxLifetime time.Duration

+ DSN string

+ LogLevel logger.LogLevel

+ MaxIdleConns int

+ MaxOpenConns int

+ Prefix string

type ClickHouseOption

+ func WithClickHouseDSN(dsn string) ClickHouseOption

Apr 16, 2025

Changes in this version

type ClickHouseConfig

+ Protocol string

+ ReadTimeout time.Duration

type ClickHouseOption

+ func WithClickHouseProtocol(protocol string) ClickHouseOption

+ func WithClickHouseReadTimeout(readTimeout time.Duration) ClickHouseOption

Apr 10, 2025

Changes in this version

+ func GetClickHouse(name string) driver.Conn

+ func GetDefaultClickHouse() driver.Conn

+ type ClickHouseComponent struct

+ var DefaultClickHouse *ClickHouseComponent

+ func GetClickHouseComponent(name string) *ClickHouseComponent

+ func NewClickHouseComponent(name string, isDefault bool, opts ...ClickHouseOption) *ClickHouseComponent

+ func (c *ClickHouseComponent) GetConn() driver.Conn

+ func (c *ClickHouseComponent) Start(ctx context.Context) error

+ func (c *ClickHouseComponent) Stop(ctx context.Context) error

+ type ClickHouseConfig struct

+ Address []string

+ Compression *clickhouse.Compression

+ ConnMaxLifetime time.Duration

+ Database string

+ Debug bool

+ DialTimeout time.Duration

+ MaxIdleConns int

+ MaxOpenConns int

+ Password string

+ Username string

+ type ClickHouseOption func(*ClickHouseConfig)

+ func WithClickHouseAddress(address []string) ClickHouseOption

+ func WithClickHouseCompression(method clickhouse.CompressionMethod) ClickHouseOption

+ func WithClickHouseConnMaxLifetime(connMaxLifetime time.Duration) ClickHouseOption

+ func WithClickHouseDatabase(database string) ClickHouseOption

+ func WithClickHouseDebug(debug bool) ClickHouseOption

+ func WithClickHouseDialTimeout(dialTimeout time.Duration) ClickHouseOption

+ func WithClickHouseMaxIdleConns(maxIdleConns int) ClickHouseOption

+ func WithClickHouseMaxOpenConns(maxOpenConns int) ClickHouseOption

+ func WithClickHousePassword(password string) ClickHouseOption

+ func WithClickHouseUsername(username string) ClickHouseOption

Mar 25, 2025

Changes in this version

type MySQLConfig

+ SlavesDSN []string

Mar 21, 2025

Changes in this version

type GinComponent

+ func (g *GinComponent) Use(middleware ...gin.HandlerFunc)

type GinOption

+ func WithGinMiddleware(middleware ...gin.HandlerFunc) GinOption

Mar 21, 2025

Changes in this version

+ func DB(name string) *gorm.DB

+ func DefaultSlaveDB() *gorm.DB

+ func GetDefaultDB() *gorm.DB

+ func GinModeForEnv(env string) string

+ func GormLogLevelForEnv(env string) logger.LogLevel

+ func SlaveDB(name string) *gorm.DB

+ type GinComponent struct

+ func NewGinComponent(opts ...GinOption) *GinComponent

+ func (g *GinComponent) GetEngine() *gin.Engine

+ func (g *GinComponent) Start(ctx context.Context) error

+ func (g *GinComponent) Stop(ctx context.Context) error

+ type GinConfig struct

+ Mode string

+ Port string

+ ShutdownTimeout time.Duration

+ type GinOption func(*GinComponent)

+ func WithGinMode(mode string) GinOption

+ func WithGinPort(port string) GinOption

+ func WithGinRouter(routerRegistrar func(*gin.Engine)) GinOption

+ func WithGinShutdownTimeout(timeout time.Duration) GinOption

+ type MySQLComponent struct

+ var DefaultDB *MySQLComponent

+ func GetMySQLComponent(name string) *MySQLComponent

+ func NewMySQLComponent(name string, config *MySQLConfig, isDefault bool) *MySQLComponent

+ func (m *MySQLComponent) Master() *gorm.DB

+ func (m *MySQLComponent) Slave() *gorm.DB

+ func (m *MySQLComponent) Start(ctx context.Context) error

+ func (m *MySQLComponent) Stop(ctx context.Context) error

+ type MySQLConfig struct

+ ConnMaxLifetime time.Duration

+ LogLevel logger.LogLevel

+ MasterDSN string

+ MaxIdleConns int

+ MaxOpenConns int

+ Prefix string

+ SlaveDSNs []string

+ type RedisClusterComponent struct

+ var GlobalRedisClusterComponent *RedisClusterComponent

+ func NewRedisClusterComponent(opts ...RedisClusterOption) *RedisClusterComponent

+ func (r *RedisClusterComponent) GetClient() *redis.ClusterClient

+ func (r *RedisClusterComponent) Start(ctx context.Context) error

+ func (r *RedisClusterComponent) Stop(ctx context.Context) error

+ type RedisClusterOption func(*RedisClusterComponent)

+ func WithClusterAddrs(addrs []string) RedisClusterOption

+ func WithClusterMaxRetries(maxRetries int) RedisClusterOption

+ func WithClusterMaxRetryBackoff(maxRetryBackoff time.Duration) RedisClusterOption

+ func WithClusterMinIdleConns(minIdleConns int) RedisClusterOption

+ func WithClusterMinRetryBackoff(minRetryBackoff time.Duration) RedisClusterOption

+ func WithClusterPassword(password string) RedisClusterOption

+ func WithClusterPoolSize(poolSize int) RedisClusterOption

+ func WithClusterPoolTimeout(poolTimeout time.Duration) RedisClusterOption

+ func WithClusterReadTimeout(readTimeout time.Duration) RedisClusterOption

+ func WithClusterRouteRandomly(routeRandomly bool) RedisClusterOption

+ func WithClusterTimeout(timeout time.Duration) RedisClusterOption

+ func WithClusterWriteTimeout(writeTimeout time.Duration) RedisClusterOption

+ type RedisComponent struct

+ var GlobalRedisComponent *RedisComponent

+ func NewRedisComponent(opts ...RedisOption) *RedisComponent

+ func (r *RedisComponent) GetClient() *redis.Client

+ func (r *RedisComponent) Start(ctx context.Context) error

+ func (r *RedisComponent) Stop(ctx context.Context) error

+ type RedisOption func(*RedisComponent)

+ func WithRedisAddr(addr string) RedisOption

+ func WithRedisDB(db int) RedisOption

+ func WithRedisMaxRetries(maxRetries int) RedisOption

+ func WithRedisMaxRetryBackoff(maxRetryBackoff time.Duration) RedisOption

+ func WithRedisMinIdleConns(minIdleConns int) RedisOption

+ func WithRedisMinRetryBackoff(minRetryBackoff time.Duration) RedisOption

+ func WithRedisPassword(password string) RedisOption

+ func WithRedisPoolSize(poolSize int) RedisOption

+ func WithRedisPoolTimeout(poolTimeout time.Duration) RedisOption

+ func WithRedisReadTimeout(readTimeout time.Duration) RedisOption

+ func WithRedisWriteTimeout(writeTimeout time.Duration) RedisOption