redis

package
v1.1.5-0...-dfb45c8 Latest Latest
Warning

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

 Go to latest Published: Jan 27, 2021 License: MIT Imports: 15 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	ClusterType = "cluster"
	NodeType    = "node"
	Nil         = red.Nil
)

Variables

View Source 
var (
	ErrEmptyHost = errors.New("empty redis host")
	ErrEmptyType = errors.New("empty redis type")
	ErrEmptyKey  = errors.New("empty redis key")
)
View Source 
var ErrNilNode = errors.New("nil redis node")

Functions

This section is empty.

Types

type ClosableNode 

type ClosableNode interface {
	RedisNode
	Close()
}

func CreateBlockingNode 

func CreateBlockingNode(r *Redis) (ClosableNode, error)

type FloatCmd 

type FloatCmd = red.FloatCmd

type GeoLocation 

type GeoLocation = red.GeoLocation

GeoLocation is used with GeoAdd to add geospatial location.

type GeoPos 

type GeoPos = red.GeoPos

type GeoRadiusQuery 

type GeoRadiusQuery = red.GeoRadiusQuery

GeoRadiusQuery is used with GeoRadius to query geospatial index.

type IntCmd 

type IntCmd = red.IntCmd

type Map 

type Map map[string]string

type Pair 

type Pair struct {
	Key   string
	Score int64
}

type Pipeliner 

type Pipeliner = red.Pipeliner

type Redis 

type Redis struct {
	Addr string
	Type string
	Pass string
	// contains filtered or unexported fields
}

thread-safe

func NewRedis 

func NewRedis(redisAddr, redisType string, redisPass ...string) *Redis

func (*Redis) Blpop 

func (s *Redis) Blpop(redisNode RedisNode, key string) (string, error)

Use passed in redis connection to execute blocking queries Doesn't benefit from pooling redis connections of blocking queries

func (*Redis) BlpopEx 

func (s *Redis) BlpopEx(redisNode RedisNode, key string) (string, bool, error)

func (*Redis) Del 

func (s *Redis) Del(keys ...string) (val int, err error)

func (*Redis) Eval 

func (s *Redis) Eval(script string, keys []string, args ...interface{}) (val interface{}, err error)

func (*Redis) Exists 

func (s *Redis) Exists(key string) (val bool, err error)

func (*Redis) Expire 

func (s *Redis) Expire(key string, seconds int) error

func (*Redis) Expireat 

func (s *Redis) Expireat(key string, expireTime int64) error

func (*Redis) GeoAdd 

func (s *Redis) GeoAdd(key string, geoLocation ...*GeoLocation) (val int64, err error)

func (*Redis) GeoDist 

func (s *Redis) GeoDist(key string, member1, member2, unit string) (val float64, err error)

func (*Redis) GeoHash 

func (s *Redis) GeoHash(key string, members ...string) (val []string, err error)

func (*Redis) GeoPos 

func (s *Redis) GeoPos(key string, members ...string) (val []*GeoPos, err error)

func (*Redis) GeoRadius 

func (s *Redis) GeoRadius(key string, longitude, latitude float64, query *GeoRadiusQuery) (val []GeoLocation, err error)

func (*Redis) GeoRadiusByMember 

func (s *Redis) GeoRadiusByMember(key, member string, query *GeoRadiusQuery) (val []GeoLocation, err error)

func (*Redis) Get 

func (s *Redis) Get(key string) (val string, err error)

func (*Redis) GetBit 

func (s *Redis) GetBit(key string, offset int64) (val int, err error)

func (*Redis) Hdel 

func (s *Redis) Hdel(key, field string) (val bool, err error)

func (*Redis) Hexists 

func (s *Redis) Hexists(key, field string) (val bool, err error)

func (*Redis) Hget 

func (s *Redis) Hget(key, field string) (val string, err error)

func (*Redis) Hgetall 

func (s *Redis) Hgetall(key string) (val map[string]string, err error)

func (*Redis) Hincrby 

func (s *Redis) Hincrby(key, field string, increment int) (val int, err error)

func (*Redis) Hkeys 

func (s *Redis) Hkeys(key string) (val []string, err error)

func (*Redis) Hlen 

func (s *Redis) Hlen(key string) (val int, err error)

func (*Redis) Hmget 

func (s *Redis) Hmget(key string, fields ...string) (val []string, err error)

func (*Redis) Hmset 

func (s *Redis) Hmset(key string, fieldsAndValues map[string]string) error

func (*Redis) Hset 

func (s *Redis) Hset(key, field, value string) error

func (*Redis) Hsetnx 

func (s *Redis) Hsetnx(key, field, value string) (val bool, err error)

func (*Redis) Hvals 

func (s *Redis) Hvals(key string) (val []string, err error)

func (*Redis) Incr 

func (s *Redis) Incr(key string) (val int64, err error)

func (*Redis) Incrby 

func (s *Redis) Incrby(key string, increment int64) (val int64, err error)

func (*Redis) Keys 

func (s *Redis) Keys(pattern string) (val []string, err error)

func (*Redis) Llen 

func (s *Redis) Llen(key string) (val int, err error)

func (*Redis) Lpop 

func (s *Redis) Lpop(key string) (val string, err error)

func (*Redis) Lpush 

func (s *Redis) Lpush(key string, values ...interface{}) (val int, err error)

func (*Redis) Lrange 

func (s *Redis) Lrange(key string, start int, stop int) (val []string, err error)

func (*Redis) Lrem 

func (s *Redis) Lrem(key string, count int, value string) (val int, err error)

func (*Redis) Mget 

func (s *Redis) Mget(keys ...string) (val []string, err error)

func (*Redis) Persist 

func (s *Redis) Persist(key string) (val bool, err error)

func (*Redis) Pfadd 

func (s *Redis) Pfadd(key string, values ...interface{}) (val bool, err error)

func (*Redis) Pfcount 

func (s *Redis) Pfcount(key string) (val int64, err error)

func (*Redis) Pfmerge 

func (s *Redis) Pfmerge(dest string, keys ...string) error

func (*Redis) Ping 

func (s *Redis) Ping() (val bool)

func (*Redis) Pipelined 

func (s *Redis) Pipelined(fn func(Pipeliner) error) (err error)

func (*Redis) Rpush 

func (s *Redis) Rpush(key string, values ...interface{}) (val int, err error)

func (*Redis) Sadd 

func (s *Redis) Sadd(key string, values ...interface{}) (val int, err error)

func (*Redis) Scan 

func (s *Redis) Scan(cursor uint64, match string, count int64) (keys []string, cur uint64, err error)

func (*Redis) Scard 

func (s *Redis) Scard(key string) (val int64, err error)

func (*Redis) Sdiff 

func (s *Redis) Sdiff(keys ...string) (val []string, err error)

func (*Redis) Sdiffstore 

func (s *Redis) Sdiffstore(destination string, keys ...string) (val int, err error)

func (*Redis) Set 

func (s *Redis) Set(key string, value string) error

func (*Redis) SetBit 

func (s *Redis) SetBit(key string, offset int64, value int) error

func (*Redis) Setex 

func (s *Redis) Setex(key, value string, seconds int) error

func (*Redis) Setnx 

func (s *Redis) Setnx(key, value string) (val bool, err error)

func (*Redis) SetnxEx 

func (s *Redis) SetnxEx(key, value string, seconds int) (val bool, err error)

func (*Redis) Sismember 

func (s *Redis) Sismember(key string, value interface{}) (val bool, err error)

func (*Redis) Smembers 

func (s *Redis) Smembers(key string) (val []string, err error)

func (*Redis) Spop 

func (s *Redis) Spop(key string) (val string, err error)

func (*Redis) Srandmember 

func (s *Redis) Srandmember(key string, count int) (val []string, err error)

func (*Redis) Srem 

func (s *Redis) Srem(key string, values ...interface{}) (val int, err error)

func (*Redis) Sscan 

func (s *Redis) Sscan(key string, cursor uint64, match string, count int64) (keys []string, cur uint64, err error)

func (*Redis) String 

func (s *Redis) String() string

func (*Redis) Sunion 

func (s *Redis) Sunion(keys ...string) (val []string, err error)

func (*Redis) Sunionstore 

func (s *Redis) Sunionstore(destination string, keys ...string) (val int, err error)

func (*Redis) Ttl 

func (s *Redis) Ttl(key string) (val int, err error)

func (*Redis) ZRevRangeWithScores 

func (s *Redis) ZRevRangeWithScores(key string, start, stop int64) (val []Pair, err error)

func (*Redis) Zadd 

func (s *Redis) Zadd(key string, score int64, value string) (val bool, err error)

func (*Redis) Zadds 

func (s *Redis) Zadds(key string, ps ...Pair) (val int64, err error)

func (*Redis) Zcard 

func (s *Redis) Zcard(key string) (val int, err error)

func (*Redis) Zcount 

func (s *Redis) Zcount(key string, start, stop int64) (val int, err error)

func (*Redis) Zincrby 

func (s *Redis) Zincrby(key string, increment int64, field string) (val int64, err error)

func (*Redis) Zrange 

func (s *Redis) Zrange(key string, start, stop int64) (val []string, err error)

func (*Redis) ZrangeWithScores 

func (s *Redis) ZrangeWithScores(key string, start, stop int64) (val []Pair, err error)

func (*Redis) ZrangebyscoreWithScores 

func (s *Redis) ZrangebyscoreWithScores(key string, start, stop int64) (val []Pair, err error)

func (*Redis) ZrangebyscoreWithScoresAndLimit 

func (s *Redis) ZrangebyscoreWithScoresAndLimit(key string, start, stop int64, page, size int) (
	val []Pair, err error)

func (*Redis) Zrank 

func (s *Redis) Zrank(key, field string) (val int64, err error)

func (*Redis) Zrem 

func (s *Redis) Zrem(key string, values ...interface{}) (val int, err error)

func (*Redis) Zremrangebyrank 

func (s *Redis) Zremrangebyrank(key string, start, stop int64) (val int, err error)

func (*Redis) Zremrangebyscore 

func (s *Redis) Zremrangebyscore(key string, start, stop int64) (val int, err error)

func (*Redis) Zrevrange 

func (s *Redis) Zrevrange(key string, start, stop int64) (val []string, err error)

func (*Redis) ZrevrangebyscoreWithScores 

func (s *Redis) ZrevrangebyscoreWithScores(key string, start, stop int64) (val []Pair, err error)

func (*Redis) ZrevrangebyscoreWithScoresAndLimit 

func (s *Redis) ZrevrangebyscoreWithScoresAndLimit(key string, start, stop int64, page, size int) (
	val []Pair, err error)

func (*Redis) Zrevrank 

func (s *Redis) Zrevrank(key string, field string) (val int64, err error)

func (*Redis) Zscore 

func (s *Redis) Zscore(key string, value string) (val int64, err error)

func (*Redis) Zunionstore 

func (s *Redis) Zunionstore(dest string, store ZStore, keys ...string) (val int64, err error)

type RedisConf 

type RedisConf struct {
	Host string
	Type string `json:",default=node,options=node|cluster"`
	Pass string `json:",optional"`
}

func (RedisConf) NewRedis 

func (rc RedisConf) NewRedis() *Redis

func (RedisConf) Validate 

func (rc RedisConf) Validate() error

type RedisKeyConf 

type RedisKeyConf struct {
	RedisConf
	Key string `json:",optional"`
}

func (RedisKeyConf) Validate 

func (rkc RedisKeyConf) Validate() error

type RedisLock 

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

func NewRedisLock 

func NewRedisLock(store *Redis, key string) *RedisLock

func (*RedisLock) Acquire 

func (rl *RedisLock) Acquire() (bool, error)

func (*RedisLock) Release 

func (rl *RedisLock) Release() (bool, error)

func (*RedisLock) SetExpire 

func (rl *RedisLock) SetExpire(seconds int)

type RedisNode 

type RedisNode interface {
	red.Cmdable
}

type ScriptCache 

type ScriptCache struct {
	atomic.Value
}

func GetScriptCache 

func GetScriptCache() *ScriptCache

func (*ScriptCache) GetSha 

func (sc *ScriptCache) GetSha(script string) (string, bool)

func (*ScriptCache) SetSha 

func (sc *ScriptCache) SetSha(script, sha string)

type Z 

type Z = red.Z

Z represents sorted set member.

type ZStore 

type ZStore = red.ZStore

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.