redis

Documentation

Index

• Variables
• func AddMembersToSet(key string, values ...interface{}) (interface{}, error)
• func Del(key string) error
• func DelMembersInSet(key string, values ...interface{}) error
• func Do(cmds ...interface{}) (interface{}, error)
• func Get(key string) *redis.StringCmd
• func GetAllMembersFromSet(key string) (interface{}, error)
• func GetCache(key string, v Encoder) error
• func GetCacheOne(key, subKey string) (string, error)
• func GetInt(key string) (int, error)
• func GetInt64(key string) (int64, error)
• func GetString(key string) (string, error)
• func GetUint64(key string) (uint64, error)
• func Incr(key string) (int64, error)
• func Initialize(ctx contextx.Context, opfs ...func(rdb RdbConfig))
• func LockExec(key string, f func(key string)) error
• func MembersCountOfSet(key string) (int64, error)
• func Publish(channel string, message interface{}) error
• func Set(key string, value interface{}, expiration time.Duration) error
• func SetCache(key string, v Encoder) error
• func SetInt(key string, value int) error
• func SetString(key, value string) error
• func Subscribe(f func(channel, msg string), channel ...string) error
• type Encoder
• type RdbConfig
• type Redis
  • func (rd *Redis) Close() error
  • func (rd *Redis) Del(ctx context.Context, keys ...string) *redis.IntCmd
  • func (rd *Redis) Do(ctx context.Context, args ...interface{}) *redis.Cmd
  • func (rd *Redis) Get(ctx context.Context, key string) *redis.StringCmd
  • func (rd *Redis) HGet(ctx context.Context, key, subKey string) *redis.StringCmd
  • func (rd *Redis) HGetAll(ctx context.Context, key string) *redis.StringStringMapCmd
  • func (rd *Redis) HMSet(ctx context.Context, key string, value ...interface{}) *redis.BoolCmd
  • func (rd *Redis) Incr(ctx context.Context, key string) *redis.IntCmd
  • func (rd *Redis) Ping(ctx context.Context) *redis.StatusCmd
  • func (rd *Redis) Publish(ctx context.Context, channel string, message interface{}) *redis.IntCmd
  • func (rd *Redis) Set(ctx context.Context, key string, value interface{}, expiration time.Duration) *redis.StatusCmd
  • func (rd *Redis) SetAddrs(addrs string)
  • func (rd *Redis) SetDB(db int)
  • func (rd *Redis) SetNX(ctx context.Context, key string, value interface{}, expiration time.Duration) *redis.BoolCmd
  • func (rd *Redis) SetPassword(password string)
  • func (rd *Redis) SetPingTime(pingTime time.Duration)
  • func (rd *Redis) SetUsername(username string)
  • func (rd *Redis) SetWaitTimeout(waitTime time.Duration)
  • func (rd *Redis) Subscribe(ctx context.Context, channels ...string) (*redis.PubSub, error)

Variables

var DefaultAddr = "127.0.0.1:6379"

var DefaultClusterAddrs = "127.0.0.1:7001;127.0.0.1:7002;127.0.0.1:7003;127.0.0.1:7004;127.0.0.1:7005;127.0.0.1:7006"

var NotReadyErr = errors.New("RedisNotReady")

var RDB = &Redis{}

Functions

func AddMembersToSet

func AddMembersToSet(key string, values ...interface{}) (interface{}, error)

func Del

func Del(key string) error

func DelMembersInSet

func DelMembersInSet(key string, values ...interface{}) error

func Do

func Do(cmds ...interface{}) (interface{}, error)

func Get

func Get(key string) *redis.StringCmd

func GetAllMembersFromSet

func GetAllMembersFromSet(key string) (interface{}, error)

func GetCache

func GetCache(key string, v Encoder) error

func GetCacheOne

func GetCacheOne(key, subKey string) (string, error)

func GetInt

func GetInt(key string) (int, error)

func GetInt64

func GetInt64(key string) (int64, error)

func GetString

func GetString(key string) (string, error)

func GetUint64

func GetUint64(key string) (uint64, error)

func Incr

func Incr(key string) (int64, error)

func Initialize

func Initialize(ctx contextx.Context, opfs ...func(rdb RdbConfig))

func LockExec

func LockExec(key string, f func(key string)) error

func MembersCountOfSet

func MembersCountOfSet(key string) (int64, error)

func Publish

func Publish(channel string, message interface{}) error

func Set

func Set(key string, value interface{}, expiration time.Duration) error

func SetCache

func SetCache(key string, v Encoder) error

func SetInt

func SetInt(key string, value int) error

func SetString

func SetString(key, value string) error

func Subscribe

func Subscribe(f func(channel, msg string), channel ...string) error

Types

type Encoder

type Encoder interface {
	Marshal() (map[string]string, error)
	Unmarshal(value map[string]string) error
}

type RdbConfig

type RdbConfig interface {
	SetAddrs(addrs string)
	SetUsername(username string)
	SetPassword(password string)
	SetDB(db int)
	SetWaitTimeout(waitTime time.Duration)
	SetPingTime(pingTime time.Duration)
}

type Redis

type Redis struct {
	Addrs       string // 连接地址
	Username    string // 用户名
	Password    string // 密码
	DB          int    // 数据库名
	WaitTimeout time.Duration
	PingTime    time.Duration
	// contains filtered or unexported fields
}

func (*Redis) Close

func (rd *Redis) Close() error

func (*Redis) Del

func (rd *Redis) Del(ctx context.Context, keys ...string) *redis.IntCmd

func (*Redis) Do

func (rd *Redis) Do(ctx context.Context, args ...interface{}) *redis.Cmd

func (*Redis) Get

func (rd *Redis) Get(ctx context.Context, key string) *redis.StringCmd

func (*Redis) HGet

func (rd *Redis) HGet(ctx context.Context, key, subKey string) *redis.StringCmd

func (*Redis) HGetAll

func (rd *Redis) HGetAll(ctx context.Context, key string) *redis.StringStringMapCmd

func (*Redis) HMSet

func (rd *Redis) HMSet(ctx context.Context, key string, value ...interface{}) *redis.BoolCmd

func (*Redis) Incr

func (rd *Redis) Incr(ctx context.Context, key string) *redis.IntCmd

func (*Redis) Ping

func (rd *Redis) Ping(ctx context.Context) *redis.StatusCmd

func (*Redis) Publish

func (rd *Redis) Publish(ctx context.Context, channel string, message interface{}) *redis.IntCmd

func (*Redis) Set

func (rd *Redis) Set(ctx context.Context, key string, value interface{}, expiration time.Duration) *redis.StatusCmd

func (*Redis) SetAddrs

func (rd *Redis) SetAddrs(addrs string)

func (*Redis) SetDB

func (rd *Redis) SetDB(db int)

func (*Redis) SetNX

func (rd *Redis) SetNX(ctx context.Context, key string, value interface{}, expiration time.Duration) *redis.BoolCmd

func (*Redis) SetPassword

func (rd *Redis) SetPassword(password string)

func (*Redis) SetPingTime

func (rd *Redis) SetPingTime(pingTime time.Duration)

func (*Redis) SetUsername

func (rd *Redis) SetUsername(username string)

func (*Redis) SetWaitTimeout

func (rd *Redis) SetWaitTimeout(waitTime time.Duration)

func (*Redis) Subscribe

func (rd *Redis) Subscribe(ctx context.Context, channels ...string) (*redis.PubSub, error)