redis

package
v0.0.0-...-5870b03 Latest Latest
Warning

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

Go to latest
Published: Nov 10, 2023 License: GPL-3.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var DefaultIns = &Client{
	Marshal:   encoding.JSON.Marshal,
	Unmarshal: encoding.JSON.Unmarshal,
}
View Source
var ErrNotSupportCluster = errors.New("not support cluster")
View Source
var ErrParmasNotEnough = errors.New("params not enough")
View Source
var OK = "OK"

Functions

func AddPrefix

func AddPrefix(s string) string

func Close

func Close() error

func Decr

func Decr(key string) (value int64, err error)

func DecrBy

func DecrBy(key string, delta int64) (value int64, err error)

func Del

func Del(keys ...string) (num int64, err error)

func Do

func Do(a radix.Action) error

func Expire

func Expire(key string, expiration int64) (b bool, err error)

func GeoAdd

func GeoAdd(key string, members ...interface{}) (num int64, err error)

geo GEOADD key longitude latitude member [longitude latitude member ...]

func GeoDist

func GeoDist(key string, args ...interface{}) (distance float64, err error)

GEODIST key member1 member2 [unit]]

func GeoHash

func GeoHash(key string, members ...string) (values []string, err error)

GEOHASH key member [member ...]

func GeoPos

func GeoPos(key string, members ...string) (values [][]float64, err error)

GEOPOS key member [member ...]

func GeoRadius

func GeoRadius(key string, args ...interface{}) (values [][]interface{}, err error)

GEORADIUS key longitude latitude radius m|km|ft|mi [WITHCOORD] [WITHDIST] [WITHHASH] [COUNT count]

func GeoRadiusByMember

func GeoRadiusByMember(key string, args ...interface{}) (values [][]interface{}, err error)

GEORADIUSBYMEMBER key member radius m|km|ft|mi [WITHCOORD] [WITHDIST] [WITHHASH] [COUNT count]

func Get

func Get(recv interface{}, key string) (b bool, err error)

func GetPrefix

func GetPrefix() string

func HDel

func HDel(key string, fields ...string) (num int64, err error)

func HExists

func HExists(key, field string) (b bool, err error)

func HGet

func HGet(recv interface{}, key, field string) (b bool, err error)

func HIncrBy

func HIncrBy(key, field string, delta int64) (value int64, err error)

func HSet

func HSet(key, field string, value interface{}) (err error)

func Incr

func Incr(key string) (value int64, err error)

func IncrBy

func IncrBy(key string, delta int64) (value int64, err error)

func IsExist

func IsExist(key string) (isExist bool, err error)

func LLen

func LLen(key string) (num int64, err error)

func LPop

func LPop(recv interface{}, key string) (b bool, err error)

func LPush

func LPush(key string, values ...interface{}) (num int64, err error)

func MGet

func MGet(keys ...string) (recv [][]byte, err error)

需要自行Unmarshal

func MSet

func MSet(items ...interface{}) (err error)

func Marshal

func Marshal(v interface{}) ([]byte, error)

func RPop

func RPop(recv interface{}, key string) (b bool, err error)

func RPush

func RPush(key string, values ...interface{}) (num int64, err error)

func Rename

func Rename(oldKey, newKey string) (err error)

集群不支持RENAME

func RenameNx

func RenameNx(oldKey, newKey string) (b bool, err error)

集群不支持RENAMENX

func SAdd

func SAdd(key string, args ...interface{}) (num int64, err error)

func SCard

func SCard(key string) (num int64, err error)

func SDiffStore

func SDiffStore(key string, args ...interface{}) (num int64, err error)

SDiffStore 集群不支持SDiffStore.

使用hash tag可以支持集群.

func SIsMember

func SIsMember(key, member string) (b bool, err error)

func Set

func Set(key string, args ...interface{}) (b bool, err error)

args可以是以下任意组合 NX XX EX seconds PX milliseconds

func SetEx

func SetEx(key string, value interface{}, expiration int64) (err error)

set的复杂格式,支持过期时间

func SetNx

func SetNx(key string, value interface{}) (b bool, err error)

func SetNxEx

func SetNxEx(key string, value interface{}, expiration int64) (b bool, err error)

set的复杂格式,支持过期时间,当key存在的时候不保存

func Ttl

func Ttl(key string) (num int64, err error)

func Unmarshal

func Unmarshal(data []byte, v interface{}) error

func ZAdd

func ZAdd(key string, args ...interface{}) (num int64, err error)

func ZIncrBy

func ZIncrBy(key, member string, increment int64) (num int64, err error)

func ZRange

func ZRange(key string, start, stop int64) (values map[string]int64, err error)

注意,返回的map不是有序的

func ZRem

func ZRem(key string, members ...interface{}) (num int64, err error)

func ZRevRange

func ZRevRange(key string, start, stop int64) (values map[string]int64, err error)

注意,返回的map不是有序的,所以其实和ZRange一样

Types

type Client

type Client struct {

	//如果以下属性是nil,则原生写入,只支持简单的数据类型
	Marshal func(interface{}) ([]byte, error)
	//不管以下属性是否nil,MGet的结果都需要自行处理
	Unmarshal func([]byte, interface{}) error
	// contains filtered or unexported fields
}

func Clone

func Clone(src ...*Client) (dst *Client, err error)

不能Close,会影响之前的连接

func New

func New(redisConfig configs.RedisConfig) (c *Client, err error)

func (*Client) AddPrefix

func (c *Client) AddPrefix(s string) string

func (*Client) Close

func (c *Client) Close() error

func (*Client) Decr

func (c *Client) Decr(key string) (value int64, err error)

func (*Client) DecrBy

func (c *Client) DecrBy(key string, delta int64) (value int64, err error)

func (*Client) Del

func (c *Client) Del(keys ...string) (num int64, err error)

func (*Client) Do

func (c *Client) Do(a radix.Action) error

func (*Client) Expire

func (c *Client) Expire(key string, expiration int64) (b bool, err error)

func (*Client) GeoAdd

func (c *Client) GeoAdd(key string, members ...interface{}) (num int64, err error)

geo GEOADD key longitude latitude member [longitude latitude member ...]

func (*Client) GeoDist

func (c *Client) GeoDist(key string, args ...interface{}) (distance float64, err error)

GEODIST key member1 member2 [unit]]

func (*Client) GeoHash

func (c *Client) GeoHash(key string, members ...string) (values []string, err error)

GEOHASH key member [member ...]

func (*Client) GeoPos

func (c *Client) GeoPos(key string, members ...string) (values [][]float64, err error)

GEOPOS key member [member ...]

func (*Client) GeoRadius

func (c *Client) GeoRadius(key string, args ...interface{}) (values [][]interface{}, err error)

GEORADIUS key longitude latitude radius m|km|ft|mi [WITHCOORD] [WITHDIST] [WITHHASH] [COUNT count]

func (*Client) GeoRadiusByMember

func (c *Client) GeoRadiusByMember(key string, args ...interface{}) (values [][]interface{}, err error)

GEORADIUSBYMEMBER key member radius m|km|ft|mi [WITHCOORD] [WITHDIST] [WITHHASH] [COUNT count]

func (*Client) Get

func (c *Client) Get(recv interface{}, key string) (b bool, err error)

func (*Client) GetPrefix

func (c *Client) GetPrefix() string

func (*Client) HDel

func (c *Client) HDel(key string, fields ...string) (num int64, err error)

func (*Client) HExists

func (c *Client) HExists(key, field string) (b bool, err error)

func (*Client) HGet

func (c *Client) HGet(recv interface{}, key, field string) (b bool, err error)

func (*Client) HIncrBy

func (c *Client) HIncrBy(key, field string, delta int64) (value int64, err error)

func (*Client) HSet

func (c *Client) HSet(key, field string, value interface{}) (err error)

func (*Client) Incr

func (c *Client) Incr(key string) (value int64, err error)

func (*Client) IncrBy

func (c *Client) IncrBy(key string, delta int64) (value int64, err error)

func (*Client) IsExist

func (c *Client) IsExist(key string) (isExist bool, err error)

func (*Client) LLen

func (c *Client) LLen(key string) (num int64, err error)

func (*Client) LPop

func (c *Client) LPop(recv interface{}, key string) (b bool, err error)

func (*Client) LPush

func (c *Client) LPush(key string, values ...interface{}) (num int64, err error)

func (*Client) MGet

func (c *Client) MGet(keys ...string) (recv [][]byte, err error)

需要自行Unmarshal

func (*Client) MSet

func (c *Client) MSet(items ...interface{}) (err error)

func (*Client) RPop

func (c *Client) RPop(recv interface{}, key string) (b bool, err error)

func (*Client) RPush

func (c *Client) RPush(key string, values ...interface{}) (num int64, err error)

func (*Client) Rename

func (c *Client) Rename(oldKey, newKey string) (err error)

集群不支持RENAME

func (*Client) RenameNx

func (c *Client) RenameNx(oldKey, newKey string) (b bool, err error)

集群不支持RENAMENX

func (*Client) SAdd

func (c *Client) SAdd(key string, args ...interface{}) (num int64, err error)

func (*Client) SCard

func (c *Client) SCard(key string) (num int64, err error)

func (*Client) SDiffStore

func (c *Client) SDiffStore(key string, args ...interface{}) (num int64, err error)

func (*Client) SIsMember

func (c *Client) SIsMember(key, member string) (b bool, err error)

func (*Client) Set

func (c *Client) Set(key string, args ...interface{}) (b bool, err error)

args可以是以下任意组合 NX XX EX seconds PX milliseconds

func (*Client) SetEx

func (c *Client) SetEx(key string, value interface{}, expiration int64) (err error)

set的复杂格式,支持过期时间

func (*Client) SetNx

func (c *Client) SetNx(key string, value interface{}) (b bool, err error)

func (*Client) SetNxEx

func (c *Client) SetNxEx(key string, value interface{}, expiration int64) (b bool, err error)

set的复杂格式,支持过期时间,当key存在的时候不保存

func (*Client) Ttl

func (c *Client) Ttl(key string) (num int64, err error)

func (*Client) ZAdd

func (c *Client) ZAdd(key string, args ...interface{}) (num int64, err error)

func (*Client) ZIncrBy

func (c *Client) ZIncrBy(key, member string, increment int64) (num int64, err error)

func (*Client) ZRange

func (c *Client) ZRange(key string, start, stop int64) (values map[string]int64, err error)

注意,返回的map不是有序的

func (*Client) ZRem

func (c *Client) ZRem(key string, members ...interface{}) (num int64, err error)

func (*Client) ZRevRange

func (c *Client) ZRevRange(key string, start, stop int64) (values map[string]int64, err error)

注意,返回的map不是有序的,所以其实和ZRange一样

Jump to

Keyboard shortcuts

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