rgrediscluster

Documentation

Index

• func Start(cfg Config) (key string, err error)
• type Client
  • func Pool(key string) (client *Client, err error)
  • func (client *Client) Del(key string) bool
  • func (client *Client) Expire(key string, t time.Duration) (bool, error)
  • func (client *Client) Get(key string) (string, error)
  • func (client *Client) GetRedisClient() (baseClient redis.Cmdable, err error)
  • func (client *Client) HDel(key string, field string) (res int64, err error)
  • func (client *Client) HGet(key string, field string) (res string, err error)
  • func (client *Client) HGetAll(key string) (res map[string]string, err error)
  • func (client *Client) HIncrby(key, field string, value int64) (res int64, err error)
  • func (client *Client) HKeys(key string) (res []string, err error)
  • func (client *Client) HMGet(key string, field []string) (res []interface{}, err error)
  • func (client *Client) HMSet(key string, fields map[string]interface{}) (res string, err error)
  • func (client *Client) HSet(table, field string, value interface{}) (bool, error)
  • func (client *Client) Incrby(key string, value int64) (int64, error)
  • func (client *Client) LPop(key string) (string, error)
  • func (client *Client) LPush(key string, value string) (int64, error)
  • func (client *Client) LRange(key string, start int64, end int64) (res []string, err error)
  • func (client *Client) RPop(key string) (string, error)
  • func (client *Client) RPush(key string, value string) (int64, error)
  • func (client *Client) SAdd(key string, param ...interface{}) (res int64, err error)
  • func (client *Client) SIsMember(key string, member interface{}) (res bool, err error)
  • func (client *Client) SMembers(key string) (res []string, err error)
  • func (client *Client) SRem(key string, param ...interface{}) (res int64, err error)
  • func (client *Client) SetPersist(key string) (res bool, err error)
  • func (client *Client) Setex(key string, val string, t time.Duration) (bool, error)
  • func (client *Client) Setnx(key string, val string, t time.Duration) (bool, error)
  • func (client *Client) Zadd(key string, score float64, member string) (res int64, err error)
  • func (client *Client) ZrangeByScore(key string, min string, max string, offset int64, count int64) (res []string, err error)
  • func (client *Client) Zrank(key string, member string) (res int64, err error)
  • func (client *Client) Zscore(key string, member string) (res float64, err error)
• type Config

Functions

func Start

func Start(cfg Config) (key string, err error)

Start 启动 集群模式，返回key，通过key获取链接对象，调用redis方法执行 @Param : @Return : @Author : LiJunDong @Time : 2022-05-31

Types

type Client

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

func Pool

func Pool(key string) (client *Client, err error)

func (*Client) Del

func (client *Client) Del(key string) bool

* @Content : 删除key * @Param : * @Return : * @Author : LiJunDong * @Time : 2021-09-09

func (*Client) Expire

func (client *Client) Expire(key string, t time.Duration) (bool, error)

* @Content : 过期设置 * @Param : * @Return : * @Author : LiJunDong * @Time : 2021-10-20

func (*Client) Get

func (client *Client) Get(key string) (string, error)

Get * @Content : string类型 获取 * @Param : * @Return : * @Author : LiJunDong * @Time : 2021-09-09

func (*Client) GetRedisClient

func (client *Client) GetRedisClient() (baseClient redis.Cmdable, err error)

func (*Client) HDel

func (client *Client) HDel(key string, field string) (res int64, err error)

* @Content : HDel * @Param : * @Return : * @Author : LiJunDong * @Time : 2022-02-18

func (*Client) HGet

func (client *Client) HGet(key string, field string) (res string, err error)

* @Content : HGet * @Param : * @Return : * @Author : LiJunDong * @Time : 2021-11-29

func (*Client) HGetAll

func (client *Client) HGetAll(key string) (res map[string]string, err error)

* @Content : HGetAll * @Param : * @Return : * @Author : LiJunDong * @Time : 2021-11-29

func (*Client) HIncrby

func (client *Client) HIncrby(key, field string, value int64) (res int64, err error)

* @Content : hash字段incrby * @Param : * @Return : * @Author : LiJunDong * @Time : 2021-11-26

func (*Client) HKeys

func (client *Client) HKeys(key string) (res []string, err error)

func (*Client) HMGet

func (client *Client) HMGet(key string, field []string) (res []interface{}, err error)

* @Content : HMGet * @Param : * @Return : * @Author : LiJunDong * @Time : 2021-11-29

func (*Client) HMSet

func (client *Client) HMSet(key string, fields map[string]interface{}) (res string, err error)

* @Content : HMget * @Param : * @Return : * @Author : LiJunDong * @Time : 2021-11-29

func (*Client) HSet

func (client *Client) HSet(table, field string, value interface{}) (bool, error)

* @Content : hash * @Param : * @Return : * @Author : LiJunDong * @Time : 2021-11-05

func (*Client) Incrby

func (client *Client) Incrby(key string, value int64) (int64, error)

* @Content : 自增 * @Param : * @Return : * @Author : LiJunDong * @Time : 2021-09-09

func (*Client) LPop

func (client *Client) LPop(key string) (string, error)

* @Content : list头部弹出一个 * @Param : * @Return : * @Author : LiJunDong * @Time : 2021-09-09

func (*Client) LPush

func (client *Client) LPush(key string, value string) (int64, error)

* @Content : list头部插入一个 * @Param : * @Return : * @Author : LiJunDong * @Time : 2021-09-09

func (*Client) LRange

func (client *Client) LRange(key string, start int64, end int64) (res []string, err error)

* @Content : list获取所有 * @Param : * @Return : * @Author : LiJunDong * @Time : 2021-09-09

func (*Client) RPop

func (client *Client) RPop(key string) (string, error)

* @Content : list尾部弹出一个 * @Param : * @Return : * @Author : LiJunDong * @Time : 2021-09-09

func (*Client) RPush

func (client *Client) RPush(key string, value string) (int64, error)

* @Content : list尾部插入一个 * @Param : * @Return : * @Author : LiJunDong * @Time : 2021-09-09

func (*Client) SAdd

func (client *Client) SAdd(key string, param ...interface{}) (res int64, err error)

* @Content : SAdd * @Param : * @Return : * @Author : LiJunDong * @Time : 2021-11-11

func (*Client) SIsMember

func (client *Client) SIsMember(key string, member interface{}) (res bool, err error)

func (*Client) SMembers

func (client *Client) SMembers(key string) (res []string, err error)

* @Content : SMembers * @Param : * @Return : * @Author : LiJunDong * @Time : 2021-11-11

func (*Client) SRem

func (client *Client) SRem(key string, param ...interface{}) (res int64, err error)

* @Content : SRem * @Param : * @Return : * @Author : LiJunDong * @Time : 2021-11-11

func (*Client) SetPersist

func (client *Client) SetPersist(key string) (res bool, err error)

func (*Client) Setex

func (client *Client) Setex(key string, val string, t time.Duration) (bool, error)

Setex * @Content : 设置可以有失效时间的string类型 t可以不传 * @Param : * @Return : * @Author : LiJunDong * @Time : 2021-09-09

func (*Client) Setnx

func (client *Client) Setnx(key string, val string, t time.Duration) (bool, error)

* @Content : 设置不存在的有失效时间的string类型，如果存在则返回false * @Param : * @Return : * @Author : LiJunDong * @Time : 2021-09-09

func (*Client) Zadd

func (client *Client) Zadd(key string, score float64, member string) (res int64, err error)

func (*Client) ZrangeByScore

func (client *Client) ZrangeByScore(key string, min string, max string, offset int64, count int64) (res []string, err error)

func (*Client) Zrank

func (client *Client) Zrank(key string, member string) (res int64, err error)

func (*Client) Zscore

func (client *Client) Zscore(key string, member string) (res float64, err error)

type Config

type Config struct {
	Addrs        []string // 集群链接地址
	Password     string   // 链接认证
	PoolSize     int      // 链接池大小
	MinIdleConns int      // 初始化连接数
	DB           int      // DB
	TimeOut      int64
}

<LiJunDong : 2022-03-30 21:21:22> --- redis配置