envinit

package
v0.0.0-...-3e16b30 Latest Latest
Warning

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

Go to latest
Published: Mar 27, 2024 License: MIT Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var Dbs map[string]*xorm.Engine

Dbs 分库分表数据库名称映射

Functions

func ConnectByEngine

func ConnectByEngine(en string, dsnPath string) (*xorm.Engine, error)

InitMysql 链接数据库 path 为 dsn 带mysql:// * * @param en 引擎类型 mysql 或 sqlite3

func InitDb

func InitDb(namespace, dsn string) error

dsn 带 mysql://

func InitRedis

func InitRedis(key, server, password string, maxConn int)

InitRedis 初始化 redis main 函数利解决

Types

type RdsConn

type RdsConn struct {
	Conn redis.Conn
}

RdsConn 所有操作绑定的这个链接上

func GetRdsConn

func GetRdsConn(key string) (*RdsConn, bool)

GetRdsConn 获取一个新链接, 需要检查是否正确

func (*RdsConn) Close

func (r *RdsConn) Close()

Close 链接用完需要释放

func (*RdsConn) Decr

func (r *RdsConn) Decr(key string) (int, error)

Decr 计数器减1

func (*RdsConn) Del

func (r *RdsConn) Del(key ...interface{}) (int, error)

Del 删除键

func (*RdsConn) Exists

func (r *RdsConn) Exists(key string) (bool, error)

Exists 验证 key 是否存在

func (*RdsConn) Expire

func (r *RdsConn) Expire(key string, t int) error

Expire 设置key的过期时间

func (*RdsConn) Get

func (r *RdsConn) Get(key string) (int, error)

Get 获取key值

func (*RdsConn) GetInt

func (r *RdsConn) GetInt(key string) (int64, error)

func (*RdsConn) GetKeys

func (r *RdsConn) GetKeys(tag string) ([]string, error)

GetKeys KEYS

func (*RdsConn) GetString

func (r *RdsConn) GetString(key string) (string, error)

func (*RdsConn) HDel

func (r *RdsConn) HDel(key string, field string) (int, error)

HDel HDel

func (*RdsConn) HGetAllInt

func (r *RdsConn) HGetAllInt(key string) (map[string]int, error)

HGetAllInt 获取所有

func (*RdsConn) HGetAllString

func (r *RdsConn) HGetAllString(key string) (map[string]string, error)

HGetAllString 获取所有

func (*RdsConn) HGetInt

func (r *RdsConn) HGetInt(key, field string) (int, error)

HGetInt 获取一个int值

func (*RdsConn) HGetInt64

func (r *RdsConn) HGetInt64(key, field string) (int64, error)

HGetInt 获取一个int值

func (*RdsConn) HGetString

func (r *RdsConn) HGetString(key string, field interface{}) (string, error)

HGetString 获取一个hash值

func (*RdsConn) HIncrBy

func (r *RdsConn) HIncrBy(key, field string, n int) (int, error)

HIncrBy +-

func (*RdsConn) HKeys

func (r *RdsConn) HKeys(key string) ([]string, error)

HKeys ...

func (*RdsConn) HLen

func (r *RdsConn) HLen(key string) (int, error)

HLen ...

func (*RdsConn) HMGetString

func (r *RdsConn) HMGetString(key string, fields []interface{}) ([]string, error)

HMGetString 获取部分key值

func (*RdsConn) HMSet

func (r *RdsConn) HMSet(key string, value interface{}) (interface{}, error)

HMSet value 可以为slice []interface{} {"k1","v1","k2","v2"}

value 可以为map map[interface{}]interface{}

{
		"k1":"v1",
		"k2":"v2",
}

使用详情见test

func (*RdsConn) HSet

func (r *RdsConn) HSet(key string, field string, val interface{}) (int, error)

HSet HSet

func (*RdsConn) HSetNx

func (r *RdsConn) HSetNx(key string, field string, val interface{}) (int, error)

HSetNx HSet不存在就设置值

func (*RdsConn) Incr

func (r *RdsConn) Incr(key string) (int, error)

Incr 计数器加1

func (*RdsConn) LPop

func (r *RdsConn) LPop(key string) (string, error)

LPop 从队列头部取出数据

func (*RdsConn) Publish

func (r *RdsConn) Publish(key string, value string) (int64, error)

Publish ...

func (*RdsConn) RPush

func (r *RdsConn) RPush(key string, value string) (int, error)

RPush 插入队列尾部

func (*RdsConn) SAdd

func (r *RdsConn) SAdd(key string, val interface{}) (int, error)

SAdd 集合添加元素 1: 新元素添加成功 0: 元素已存在

func (*RdsConn) SPop

func (r *RdsConn) SPop(key string) (string, error)

SPop 随机弹出一个数据

func (*RdsConn) Set

func (r *RdsConn) Set(key string, val interface{}) (interface{}, error)

Set 不管key存不存在,都添加

func (*RdsConn) SetEx

func (r *RdsConn) SetEx(key string, expire int64, val interface{}) (interface{}, error)

SetEx 不管key存不存在,都添加

func (*RdsConn) SetNx

func (r *RdsConn) SetNx(key string, val interface{}) (int, error)

SetNx 如果key不存在,就添加

func (*RdsConn) SisMember

func (r *RdsConn) SisMember(key string, val interface{}) (int, error)

SisMember 检查集合中是否有成员val

func (*RdsConn) ZAdd

func (r *RdsConn) ZAdd(key string, member string, v int64) (int64, error)

ZAdd 添加 1 新创建 0 老key

func (*RdsConn) ZIncrBy

func (r *RdsConn) ZIncrBy(key string, member string, v int64) (int64, error)

ZIncrBy 增量

func (*RdsConn) ZRange

func (r *RdsConn) ZRange(key string, start, end int64) ([]string, error)

ZRange ...

func (*RdsConn) ZRangeWithScore

func (r *RdsConn) ZRangeWithScore(key string, start, end int64) (map[string]int64, error)

ZRangeWithScore ...

func (*RdsConn) ZRevRange

func (r *RdsConn) ZRevRange(key string, start, end int64) ([]string, error)

ZRevRange ...

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL