before

Documentation

Index

• Variables
• func CloseRedis()
• func ConnectionDatabase(config *DatabaseConnetStu) error
• func ConnectionRedis(config *RedisConnetionStu)
• func CreateGin(isProd bool)
• func DBTransaction(call func(tx *gorm.DB) error) error
• func GetDB(tx ...*gorm.DB) *gorm.DB
• func RdbDel(key string) error
• func RdbGet(key string) (string, error)
• func RdbKeys() ([]string, error)
• func RdbPublish(ctx context.Context, ch, msg string) error
• func RdbSAdd(key string, members ...interface{}) error
• func RdbSCard(key string) (int64, error)
• func RdbSIsMember(key string, val interface{}) (bool, error)
• func RdbSMembers(key string) ([]string, error)
• func RdbSRem(key string, members ...interface{}) (int64, error)
• func RdbSet(key string, val interface{}, ttl time.Duration) error
• func RdbSubscribe(ctx context.Context, ch string) (string, error)
• func RedisPing(ctx context.Context) (string, error)
• func RegisterValidate()
• type DatabaseConnetStu
• type RedisConnetionStu

Variables

var Database *gorm.DB

var Gin *gin.Engine

var Valid *validator.Validate

Functions

func CloseRedis

func CloseRedis()

关闭redis，回收资源时使用

func ConnectionDatabase

func ConnectionDatabase(config *DatabaseConnetStu) error

*

• 数据库连接
• @Return 是否连接成功

func ConnectionRedis

func ConnectionRedis(config *RedisConnetionStu)

*

• 连接Mysql服务

func CreateGin

func CreateGin(isProd bool)

func DBTransaction

func DBTransaction(call func(tx *gorm.DB) error) error

*

• 数据库事务

func GetDB

func GetDB(tx ...*gorm.DB) *gorm.DB

*

• 获取数据库

func RdbDel

func RdbDel(key string) error

*

• 删除数据
• @Param key string 需要删除的键的名称

func RdbGet

func RdbGet(key string) (string, error)

*

• 获取string类型数据
• @Param key string 键名称
• @Return 为 nil 时表示获取成功

func RdbKeys

func RdbKeys() ([]string, error)

*

• 查询所有key

func RdbPublish

func RdbPublish(ctx context.Context, ch, msg string) error

*

• 发布消息
• @Param ch string 消息对应的通道的名称
• @Param msg string 消息内容

func RdbSAdd

func RdbSAdd(key string, members ...interface{}) error

*

• 添加Set类型的数据
• @Param key string 键名称
• @Param members 需要保存到集合中的值

func RdbSCard

func RdbSCard(key string) (int64, error)

*

• 返回无序集合中的个数
• @Param key string 键名称

func RdbSIsMember

func RdbSIsMember(key string, val interface{}) (bool, error)

*

• 判断某个值是否存在某个无序集合中
• @Param key string 键名称
• @Param val interface{} 需要判断的值

func RdbSMembers

func RdbSMembers(key string) ([]string, error)

*

• 返回无序集合中的所有元素
• @Param key string 键名称
• @Return 返回的值都是以字符串保存的

func RdbSRem

func RdbSRem(key string, members ...interface{}) (int64, error)

*

• 删除无序集合中的元素
• @Param key string 键名称
• @Param members 需要删除的值

func RdbSet

func RdbSet(key string, val interface{}, ttl time.Duration) error

*

• 设置string类型的数据
• @Param key string 键名称
• @Param value interface{} 值内容，传递的值都会作为字符串保存
• @Param ttl time.Duration 过期时间，例如：time.Second * 1
• @Return 为 nil 时表示添加成功

func RdbSubscribe

func RdbSubscribe(ctx context.Context, ch string) (string, error)

*

• 订阅消息
• @Param ch string 消息对应的通道的名称

func RedisPing

func RedisPing(ctx context.Context) (string, error)

连接测试

func RegisterValidate

func RegisterValidate()

Types

type DatabaseConnetStu

type DatabaseConnetStu struct {
	DbType         string        // 数据库类型：mysql、mssql、oracle
	DbHost         string        // 连接主体：127.0.0.1
	DbPort         string        // 端口号
	DbUsername     string        // 数据库用户账号
	DbPassword     string        // 数据库用户密码
	DbName         string        // 数据库名称
	DbMaxOpenConns int           // 最大连接数
	DbMaxIdleConns int           // 最大空闲连接数量
	DbMaxLifetime  time.Duration // 最大生存时间
}

gorm 连接配置

type RedisConnetionStu

type RedisConnetionStu struct {
	RedisHost   string
	RedisPort   string
	RedisPass   string
	DialTimeout time.Duration
	ReadTimeout time.Duration
}

redis 连接配置