components

package
v1.0.2 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Mar 21, 2025 License: MIT Imports: 15 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func DB 

func DB(name string) *gorm.DB

保留原有的命名实例访问方法

func DefaultSlaveDB 

func DefaultSlaveDB() *gorm.DB

默认实例的从库访问方法

func GetDefaultDB 

func GetDefaultDB() *gorm.DB

默认实例的全局访问方法

func GinModeForEnv 

func GinModeForEnv(env string) string

GinModeForEnv 根据环境变量设置Gin模式

func GormLogLevelForEnv 

func GormLogLevelForEnv(env string) logger.LogLevel

GormLogLevelForEnv 根据环境变量设置Gorm日志级别

func SlaveDB 

func SlaveDB(name string) *gorm.DB

ReplicaDB 获取从库连接

Types

type GinComponent 

type GinComponent struct {
	// contains filtered or unexported fields
}

GinComponent Gin组件

func NewGinComponent 

func NewGinComponent(opts ...GinOption) *GinComponent

NewGinComponent 创建Gin组件

func (*GinComponent) GetEngine 

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

GetEngine 获取Gin引擎

func (*GinComponent) Start 

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

Start 启动Gin组件

func (*GinComponent) Stop 

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

Stop 停止Gin组件

type GinConfig 

type GinConfig struct {
	Port            string
	Mode            string
	ShutdownTimeout time.Duration
}

GinConfig Gin配置

type GinOption 

type GinOption func(*GinComponent)

GinOption 定义Gin选项函数类型

func WithGinMode 

func WithGinMode(mode string) GinOption

WithGinMode 设置Gin模式

func WithGinPort 

func WithGinPort(port string) GinOption

WithGinPort 设置Gin端口

func WithGinRouter 

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

WithGinRouter 设置路由注册函数

func WithGinShutdownTimeout 

func WithGinShutdownTimeout(timeout time.Duration) GinOption

WithGinShutdownTimeout 设置关闭超时时间

type MySQLComponent 

type MySQLComponent struct {
	// contains filtered or unexported fields
}

MySQLComponent MySQL组件 

var (
	DefaultDB *MySQLComponent // 添加默认实例

)

func GetMySQLComponent 

func GetMySQLComponent(name string) *MySQLComponent

获取指定实例

func NewMySQLComponent 

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

NewMySQLComponent 创建MySQL组件

func (*MySQLComponent) Master 

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

Master 获取主库连接

func (*MySQLComponent) Slave 

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

Replica 获取从库连接（轮询方式）

func (*MySQLComponent) Start 

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

Start 启动MySQL组件

func (*MySQLComponent) Stop 

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

Stop 停止MySQL组件

type MySQLConfig 

type MySQLConfig struct {
	MasterDSN       string
	SlaveDSNs       []string // 修改为切片，支持多个从库
	MaxIdleConns    int
	MaxOpenConns    int
	ConnMaxLifetime time.Duration
	LogLevel        logger.LogLevel
	Prefix          string
}

MySQLConfig MySQL配置

type RedisClusterComponent 

type RedisClusterComponent struct {
	// contains filtered or unexported fields
}

RedisClusterComponent Redis集群组件 

var GlobalRedisClusterComponent *RedisClusterComponent

全局Redis集群组件

func NewRedisClusterComponent 

func NewRedisClusterComponent(opts ...RedisClusterOption) *RedisClusterComponent

NewRedisClusterComponent 创建Redis集群组件

func (*RedisClusterComponent) GetClient 

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

GetClient 获取Redis集群客户端

func (*RedisClusterComponent) Start 

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

Start 启动Redis集群组件

func (*RedisClusterComponent) Stop 

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

Stop 停止Redis集群组件

type RedisClusterOption 

type RedisClusterOption func(*RedisClusterComponent)

RedisClusterOption 定义Redis集群选项函数类型

func WithClusterAddrs 

func WithClusterAddrs(addrs []string) RedisClusterOption

WithClusterAddrs 设置Redis集群地址

func WithClusterMaxRetries 

func WithClusterMaxRetries(maxRetries int) RedisClusterOption

WithClusterMaxRetries 设置集群最大重试次数

func WithClusterMaxRetryBackoff 

func WithClusterMaxRetryBackoff(maxRetryBackoff time.Duration) RedisClusterOption

WithClusterMaxRetryBackoff 设置集群最大重试间隔时间

func WithClusterMinIdleConns 

func WithClusterMinIdleConns(minIdleConns int) RedisClusterOption

WithClusterMinIdleConns 设置集群最小空闲连接数

func WithClusterMinRetryBackoff 

func WithClusterMinRetryBackoff(minRetryBackoff time.Duration) RedisClusterOption

WithClusterMinRetryBackoff 设置集群最小重试间隔时间

func WithClusterPassword 

func WithClusterPassword(password string) RedisClusterOption

WithClusterPassword 设置Redis集群密码

func WithClusterPoolSize 

func WithClusterPoolSize(poolSize int) RedisClusterOption

WithClusterPoolSize 设置集群连接池大小

func WithClusterPoolTimeout 

func WithClusterPoolTimeout(poolTimeout time.Duration) RedisClusterOption

WithClusterPoolTimeout 设置集群连接池超时时间

func WithClusterReadTimeout 

func WithClusterReadTimeout(readTimeout time.Duration) RedisClusterOption

WithClusterReadTimeout 设置集群读取超时时间

func WithClusterRouteRandomly 

func WithClusterRouteRandomly(routeRandomly bool) RedisClusterOption

WithClusterRouteRandomly 设置集群是否随机路由

func WithClusterTimeout 

func WithClusterTimeout(timeout time.Duration) RedisClusterOption

WithClusterTimeout 设置集群连接超时时间

func WithClusterWriteTimeout 

func WithClusterWriteTimeout(writeTimeout time.Duration) RedisClusterOption

WithClusterWriteTimeout 设置集群写入超时时间

type RedisComponent 

type RedisComponent struct {
	// contains filtered or unexported fields
}

RedisComponent Redis组件 

var GlobalRedisComponent *RedisComponent

全局Redis组件

func NewRedisComponent 

func NewRedisComponent(opts ...RedisOption) *RedisComponent

NewRedisComponent 创建Redis组件

func (*RedisComponent) GetClient 

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

GetClient 获取Redis客户端

func (*RedisComponent) Start 

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

Start 启动Redis组件

func (*RedisComponent) Stop 

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

Stop 停止Redis组件

type RedisOption 

type RedisOption func(*RedisComponent)

RedisOption 定义Redis选项函数类型

func WithRedisAddr 

func WithRedisAddr(addr string) RedisOption

WithRedisAddr 设置Redis地址

func WithRedisDB 

func WithRedisDB(db int) RedisOption

WithRedisDB 设置Redis数据库

func WithRedisMaxRetries 

func WithRedisMaxRetries(maxRetries int) RedisOption

WithRedisMaxRetries 设置最大重试次数

func WithRedisMaxRetryBackoff 

func WithRedisMaxRetryBackoff(maxRetryBackoff time.Duration) RedisOption

WithRedisMaxRetryBackoff 设置最大重试间隔时间

func WithRedisMinIdleConns 

func WithRedisMinIdleConns(minIdleConns int) RedisOption

WithRedisMinIdleConns 设置最小空闲连接数

func WithRedisMinRetryBackoff 

func WithRedisMinRetryBackoff(minRetryBackoff time.Duration) RedisOption

WithRedisMinRetryBackoff 设置最小重试间隔时间

func WithRedisPassword 

func WithRedisPassword(password string) RedisOption

WithRedisPassword 设置Redis密码

func WithRedisPoolSize 

func WithRedisPoolSize(poolSize int) RedisOption

WithRedisPoolSize 设置连接池大小

func WithRedisPoolTimeout 

func WithRedisPoolTimeout(poolTimeout time.Duration) RedisOption

WithRedisPoolTimeout 设置连接池超时时间

func WithRedisReadTimeout 

func WithRedisReadTimeout(readTimeout time.Duration) RedisOption

WithRedisReadTimeout 设置读取超时时间

func WithRedisWriteTimeout 

func WithRedisWriteTimeout(writeTimeout time.Duration) RedisOption

WithRedisWriteTimeout 设置写入超时时间

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.