rds

package
v1.1.7 Latest Latest
Warning

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

 Go to latest Published: Aug 16, 2019 License: MIT Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Rds added in v1.1.7 

type Rds struct {
	redis.Conn
}

func Ins 

func Ins(id ...string) *Rds

返回 redis 的一个连接

func (*Rds) BLPop added in v1.1.7 

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

func (*Rds) BRPop added in v1.1.7 

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

func (*Rds) BRPopLPush added in v1.1.7 

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

func (*Rds) Decr added in v1.1.7 

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

func (*Rds) DecrBy added in v1.1.7 

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

func (*Rds) Del added in v1.1.7 

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

func (*Rds) Exists added in v1.1.7 

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

func (*Rds) Expire added in v1.1.7 

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

func (*Rds) ExpireAt added in v1.1.7 

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

func (*Rds) Get added in v1.1.7 

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

func (*Rds) GetBit added in v1.1.7 

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

func (*Rds) GetRange added in v1.1.7 

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

func (*Rds) GetSet added in v1.1.7 

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

func (*Rds) HDel added in v1.1.7 

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

func (*Rds) HExists added in v1.1.7 

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

func (*Rds) HGet added in v1.1.7 

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

func (*Rds) HGetAll added in v1.1.7 

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

func (*Rds) HIncrBy added in v1.1.7 

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

func (*Rds) HIncrByFloat added in v1.1.7 

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

func (*Rds) HKeys added in v1.1.7 

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

func (*Rds) HLen added in v1.1.7 

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

func (*Rds) HMGet added in v1.1.7 

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

func (*Rds) HMSet added in v1.1.7 

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

HMSET key field value [field value ...]

func (*Rds) HScan added in v1.1.7 

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

func (*Rds) HSet added in v1.1.7 

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

func (*Rds) HSetNx added in v1.1.7 

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

func (*Rds) HStrLen added in v1.1.7 

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

func (*Rds) HVals added in v1.1.7 

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

func (*Rds) Incr added in v1.1.7 

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

func (*Rds) IncrBy added in v1.1.7 

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

func (*Rds) IncrByFloat added in v1.1.7 

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

func (*Rds) Keys added in v1.1.7 

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

func (*Rds) LIndex added in v1.1.7 

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

func (*Rds) LInsert added in v1.1.7 

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

LINSERT key BEFORE|AFTER pivot value

func (*Rds) LLen added in v1.1.7 

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

func (*Rds) LPop added in v1.1.7 

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

func (*Rds) LPush added in v1.1.7 

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

func (*Rds) LPushX added in v1.1.7 

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

func (*Rds) LRange added in v1.1.7 

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

func (*Rds) LRem added in v1.1.7 

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

func (*Rds) LSet added in v1.1.7 

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

func (*Rds) LTrim added in v1.1.7 

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

func (*Rds) MGet added in v1.1.7 

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

func (*Rds) MSet added in v1.1.7 

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

MSET key value [key value ...]

func (*Rds) MSetNx added in v1.1.7 

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

MSETNX key value [key value ...]

func (*Rds) NewSubscriber added in v1.1.7 

func (r *Rds) NewSubscriber(topic string) (*Subscriber, error)

func (*Rds) PExpire added in v1.1.7 

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

func (*Rds) PExpireAt added in v1.1.7 

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

func (*Rds) PSetEx added in v1.1.7 

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

PSETEX key milliseconds value

func (*Rds) PTtl added in v1.1.7 

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

func (*Rds) Persist added in v1.1.7 

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

func (*Rds) RPop added in v1.1.7 

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

func (*Rds) RPopLPush added in v1.1.7 

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

func (*Rds) RPush added in v1.1.7 

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

func (*Rds) RPushX added in v1.1.7 

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

func (*Rds) SAdd added in v1.1.7 

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

*

  • Sets

func (*Rds) SCard added in v1.1.7 

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

func (*Rds) SDiff added in v1.1.7 

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

func (*Rds) SDiffStore added in v1.1.7 

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

func (*Rds) SInter added in v1.1.7 

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

func (*Rds) SInterStore added in v1.1.7 

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

func (*Rds) SIsMember added in v1.1.7 

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

func (*Rds) SMembers added in v1.1.7 

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

func (*Rds) SMove added in v1.1.7 

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

func (*Rds) SPop added in v1.1.7 

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

func (*Rds) SRem added in v1.1.7 

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

func (*Rds) SScan added in v1.1.7 

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

func (*Rds) SUnion added in v1.1.7 

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

func (*Rds) SUnionStore added in v1.1.7 

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

func (*Rds) Scan added in v1.1.7 

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

SCAN cursor [MATCH pattern] [COUNT count]

func (*Rds) Set added in v1.1.7 

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 added in v1.1.7 

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

func (*Rds) SetEx added in v1.1.7 

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

func (*Rds) SetNx added in v1.1.7 

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

func (*Rds) SetRange added in v1.1.7 

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

func (*Rds) StrLen added in v1.1.7 

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

func (*Rds) Ttl added in v1.1.7 

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

func (*Rds) Type added in v1.1.7 

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

func (*Rds) ZAdd added in v1.1.7 

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 added in v1.1.7 

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

func (*Rds) ZCount added in v1.1.7 

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

func (*Rds) ZIncrBy added in v1.1.7 

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

func (*Rds) ZInterStore added in v1.1.7 

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 added in v1.1.7 

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

zrange key start stop [withscores]

func (*Rds) ZRangeByScore added in v1.1.7 

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 added in v1.1.7 

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

func (*Rds) ZRem added in v1.1.7 

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

func (*Rds) ZRemRangeByRank added in v1.1.7 

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

func (*Rds) ZRemRangeByScore added in v1.1.7 

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

func (*Rds) ZRevRange added in v1.1.7 

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

func (*Rds) ZRevRangeByScore added in v1.1.7 

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 added in v1.1.7 

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

func (*Rds) ZScan added in v1.1.7 

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

func (*Rds) ZScore added in v1.1.7 

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

func (*Rds) ZUnionStore added in v1.1.7 

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([]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.