rds

package
v1.6.2 Latest Latest
Warning

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

Go to latest
Published: May 25, 2020 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

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

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

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.6.0

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

Jump to

Keyboard shortcuts

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