rds

package
v1.6.5 Latest Latest
Warning

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

 Go to latest Published: Mar 4, 2022 License: MIT Imports: 5 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Rds 

type Rds struct {
	//	redis.Conn
	*redis.Pool
}

func Ins 

func Ins(id ...string) *Rds

返回 redis 的一个连接

func (*Rds) BLPop 

func (r *Rds) BLPop(key, timeout interface{}) (reply interface{}, err error)

func (*Rds) BRPop 

func (r *Rds) BRPop(key, timeout interface{}) (reply interface{}, err error)

func (*Rds) BRPopLPush 

func (r *Rds) BRPopLPush(source, destination, timeout interface{}) (reply interface{}, err error)

func (*Rds) Decr 

func (r *Rds) Decr(key interface{}) (reply interface{}, err error)

func (*Rds) DecrBy 

func (r *Rds) DecrBy(key, decrement interface{}) (reply interface{}, err error)

func (*Rds) Del 

func (r *Rds) Del(keys ...interface{}) (reply interface{}, err error)

func (*Rds) Do added in v1.2.6 

func (r *Rds) Do(commandName string, args ...interface{}) (reply interface{}, err error)

func (*Rds) Exists 

func (r *Rds) Exists(key interface{}) (reply interface{}, err error)

func (*Rds) Expire 

func (r *Rds) Expire(key, seconds interface{}) (reply interface{}, err error)

func (*Rds) ExpireAt 

func (r *Rds) ExpireAt(key, timestamp interface{}) (reply interface{}, err error)

func (*Rds) Get 

func (r *Rds) Get(key interface{}) (reply interface{}, err error)

func (*Rds) GetBit 

func (r *Rds) GetBit(key, offset interface{}) (reply interface{}, err error)

func (*Rds) GetConn added in v1.2.6 

func (r *Rds) GetConn() redis.Conn

func (*Rds) GetRange 

func (r *Rds) GetRange(key, start, end interface{}) (reply interface{}, err error)

func (*Rds) GetSet 

func (r *Rds) GetSet(key, value interface{}) (reply interface{}, err error)

func (*Rds) HDel 

func (r *Rds) HDel(key interface{}, fields ...interface{}) (reply interface{}, err error)

func (*Rds) HExists 

func (r *Rds) HExists(key, field interface{}) (reply interface{}, err error)

func (*Rds) HGet 

func (r *Rds) HGet(key, field interface{}) (reply interface{}, err error)

func (*Rds) HGetAll 

func (r *Rds) HGetAll(key interface{}) (reply interface{}, err error)

func (*Rds) HIncrBy 

func (r *Rds) HIncrBy(key, field, increment interface{}) (reply interface{}, err error)

func (*Rds) HIncrByFloat 

func (r *Rds) HIncrByFloat(key, field, increment interface{}) (reply interface{}, err error)

func (*Rds) HKeys 

func (r *Rds) HKeys(key interface{}) (reply interface{}, err error)

func (*Rds) HLen 

func (r *Rds) HLen(key interface{}) (reply interface{}, err error)

func (*Rds) HMGet 

func (r *Rds) HMGet(key interface{}, fields ...interface{}) (reply interface{}, err error)

func (*Rds) HMSet 

func (r *Rds) HMSet(key interface{}, fieldValues ...interface{}) (reply interface{}, err error)

HMSET key field value [field value ...]

func (*Rds) HScan 

func (r *Rds) HScan(key interface{}, cursor interface{}, opts ...interface{}) (reply interface{}, err error)

func (*Rds) HSet 

func (r *Rds) HSet(key, field, value interface{}) (reply interface{}, err error)

func (*Rds) HSetNx 

func (r *Rds) HSetNx(key, field, value interface{}) (reply interface{}, err error)

func (*Rds) HStrLen 

func (r *Rds) HStrLen(key, field interface{}) (reply interface{}, err error)

func (*Rds) HVals 

func (r *Rds) HVals(key interface{}) (reply interface{}, err error)

func (*Rds) Incr 

func (r *Rds) Incr(key interface{}) (reply interface{}, err error)

func (*Rds) IncrBy 

func (r *Rds) IncrBy(key, increment interface{}) (reply interface{}, err error)

func (*Rds) IncrByFloat 

func (r *Rds) IncrByFloat(key, increment interface{}) (reply interface{}, err error)

func (*Rds) Keys 

func (r *Rds) Keys(pattern interface{}) (reply interface{}, err error)

func (*Rds) LIndex 

func (r *Rds) LIndex(key, index interface{}) (reply interface{}, err error)

func (*Rds) LInsert 

func (r *Rds) LInsert(key, where, pivot, value interface{}) (reply interface{}, err error)

LINSERT key BEFORE|AFTER pivot value

func (*Rds) LLen 

func (r *Rds) LLen(key interface{}) (reply interface{}, err error)

func (*Rds) LPop 

func (r *Rds) LPop(key interface{}) (reply interface{}, err error)

func (*Rds) LPush 

func (r *Rds) LPush(key interface{}, values ...interface{}) (reply interface{}, err error)

func (*Rds) LPushX 

func (r *Rds) LPushX(key, value interface{}) (reply interface{}, err error)

func (*Rds) LRange 

func (r *Rds) LRange(key, start, stop interface{}) (reply interface{}, err error)

func (*Rds) LRem 

func (r *Rds) LRem(key, count, value interface{}) (reply interface{}, err error)

func (*Rds) LSet 

func (r *Rds) LSet(key, index, value interface{}) (reply interface{}, err error)

func (*Rds) LTrim 

func (r *Rds) LTrim(key, start, stop interface{}) (reply interface{}, err error)

func (*Rds) MGet 

func (r *Rds) MGet(keys ...interface{}) (reply interface{}, err error)

func (*Rds) MSet 

func (r *Rds) MSet(keyValues ...interface{}) (reply interface{}, err error)

MSET key value [key value ...]

func (*Rds) MSetNx 

func (r *Rds) MSetNx(keyValues ...interface{}) (reply interface{}, err error)

MSETNX key value [key value ...]

func (*Rds) NewSubscriber 

func (r *Rds) NewSubscriber(channel ...interface{}) (*Subscriber, error)

func (*Rds) PExpire 

func (r *Rds) PExpire(key, milliseconds interface{}) (reply interface{}, err error)

func (*Rds) PExpireAt 

func (r *Rds) PExpireAt(key, millisecondsTimestamp interface{}) (reply interface{}, err error)

func (*Rds) PSetEx 

func (r *Rds) PSetEx(key, milliseconds, value interface{}) (reply interface{}, err error)

PSETEX key milliseconds value

func (*Rds) PTtl 

func (r *Rds) PTtl(key interface{}) (reply interface{}, err error)

func (*Rds) Persist 

func (r *Rds) Persist(key interface{}) (reply interface{}, err error)

func (*Rds) Publish added in v1.4.5 

func (r *Rds) Publish(channel, message interface{}) (reply interface{}, err error)

func (*Rds) RPop 

func (r *Rds) RPop(key interface{}) (reply interface{}, err error)

func (*Rds) RPopLPush 

func (r *Rds) RPopLPush(source, destination interface{}) (reply interface{}, err error)

func (*Rds) RPush 

func (r *Rds) RPush(key interface{}, values ...interface{}) (reply interface{}, err error)

func (*Rds) RPushX 

func (r *Rds) RPushX(key, value interface{}) (reply interface{}, err error)

func (*Rds) SAdd 

func (r *Rds) SAdd(key interface{}, members ...interface{}) (reply interface{}, err error)

*

  • Sets

func (*Rds) SCard 

func (r *Rds) SCard(key interface{}) (reply interface{}, err error)

func (*Rds) SDiff 

func (r *Rds) SDiff(key interface{}, keys ...interface{}) (reply interface{}, err error)

func (*Rds) SDiffStore 

func (r *Rds) SDiffStore(destination, key interface{}, keys ...interface{}) (reply interface{}, err error)

func (*Rds) SInter 

func (r *Rds) SInter(key interface{}, keys ...interface{}) (reply interface{}, err error)

func (*Rds) SInterStore 

func (r *Rds) SInterStore(destination, key interface{}, keys ...interface{}) (reply interface{}, err error)

func (*Rds) SIsMember 

func (r *Rds) SIsMember(key, member interface{}) (reply interface{}, err error)

func (*Rds) SMembers 

func (r *Rds) SMembers(key interface{}) (reply interface{}, err error)

func (*Rds) SMove 

func (r *Rds) SMove(source, destination, member interface{}) (reply interface{}, err error)

func (*Rds) SPop 

func (r *Rds) SPop(key interface{}) (reply interface{}, err error)

func (*Rds) SRem 

func (r *Rds) SRem(key interface{}, members ...interface{}) (reply interface{}, err error)

func (*Rds) SScan 

func (r *Rds) SScan(key interface{}, cursor interface{}, options ...interface{}) (reply interface{}, err error)

func (*Rds) SUnion 

func (r *Rds) SUnion(key interface{}, keys ...interface{}) (reply interface{}, err error)

func (*Rds) SUnionStore 

func (r *Rds) SUnionStore(key interface{}, keys ...interface{}) (reply interface{}, err error)

func (*Rds) Scan 

func (r *Rds) Scan(cursor interface{}, opts ...interface{}) (reply interface{}, err error)

SCAN cursor [MATCH pattern] [COUNT count]

func (*Rds) Set 

func (r *Rds) Set(key, value interface{}, args ...interface{}) (reply interface{}, err error)

SET key value [EX seconds] [PX milliseconds] [NX|XX]

func (*Rds) SetBit 

func (r *Rds) SetBit(key, offset, value interface{}) (reply interface{}, err error)

func (*Rds) SetEx 

func (r *Rds) SetEx(key, seconds, value interface{}) (reply interface{}, err error)

func (*Rds) SetNx 

func (r *Rds) SetNx(key, value interface{}) (reply interface{}, err error)

func (*Rds) SetRange 

func (r *Rds) SetRange(key, offset, value interface{}) (reply interface{}, err error)

func (*Rds) StrLen 

func (r *Rds) StrLen(key interface{}) (reply interface{}, err error)

func (*Rds) Ttl 

func (r *Rds) Ttl(key interface{}) (reply interface{}, err error)

func (*Rds) Type 

func (r *Rds) Type(key interface{}) (reply interface{}, err error)

func (*Rds) ZAdd 

func (r *Rds) ZAdd(key interface{}, options ...interface{}) (reply interface{}, err error)

zadd key [nx|xx] [ch] [incr] score member [score member...]

func (*Rds) ZCard 

func (r *Rds) ZCard(key interface{}) (reply interface{}, err error)

func (*Rds) ZCount 

func (r *Rds) ZCount(key, min, max interface{}) (reply interface{}, err error)

func (*Rds) ZIncrBy 

func (r *Rds) ZIncrBy(key, increment, member interface{}) (reply interface{}, err error)

func (*Rds) ZInterStore 

func (r *Rds) ZInterStore(destination, numkeys, key1, key2 interface{}, opts ...interface{}) (reply interface{}, err error)

zinterstore destination numkeys key [key ...] [weights weight]

func (*Rds) ZRange 

func (r *Rds) ZRange(key, start, stop interface{}, opts ...interface{}) (reply interface{}, err error)

zrange key start stop [withscores]

func (*Rds) ZRangeByScore 

func (r *Rds) ZRangeByScore(key, min, max interface{}, opts ...interface{}) (reply interface{}, err error)

zrangebyscore key min max [withscores] [limit offset count]

func (*Rds) ZRank 

func (r *Rds) ZRank(key, member interface{}) (reply interface{}, err error)

func (*Rds) ZRem 

func (r *Rds) ZRem(key, member interface{}, members ...interface{}) (reply interface{}, err error)

func (*Rds) ZRemRangeByRank 

func (r *Rds) ZRemRangeByRank(key, start, stop interface{}) (reply interface{}, err error)

func (*Rds) ZRemRangeByScore 

func (r *Rds) ZRemRangeByScore(key, min, max interface{}) (reply interface{}, err error)

func (*Rds) ZRevRange 

func (r *Rds) ZRevRange(key, start, stop interface{}) (reply interface{}, err error)

func (*Rds) ZRevRangeByScore 

func (r *Rds) ZRevRangeByScore(key, max, min interface{}, opts ...interface{}) (reply interface{}, err error)

zrevrangebyscore key max min [withscores] [limit offset count]

func (*Rds) ZRevRank 

func (r *Rds) ZRevRank(key, member interface{}) (reply interface{}, err error)

func (*Rds) ZScan 

func (r *Rds) ZScan(key, cursor interface{}, opts ...interface{}) (reply interface{}, err error)

func (*Rds) ZScore 

func (r *Rds) ZScore(key, member interface{}) (reply interface{}, err error)

func (*Rds) ZUnionStore 

func (r *Rds) ZUnionStore(destination, numkeys, key1, key2 interface{}, opts ...interface{}) (reply interface{}, err error)

zunionstore destination numkeys key [key ...] [weights weight] [sum|min|mix]

type Subscriber 

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

func (*Subscriber) Close 

func (s *Subscriber) Close()

func (*Subscriber) Subscribe 

func (s *Subscriber) Subscribe(cb func(channel string, data []byte)) error

Source Files

View all Source files

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.