tidis

package
v0.0.0-...-0ce5a4d Latest Latest
Warning

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

 Go to latest Published: May 20, 2019 License: MIT Imports: 12 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	LHeadDirection uint8 = 0
	LTailDirection uint8 = 1

	LItemMinIndex uint64 = 1024
	LItemMaxIndex uint64 = 1<<64 - 1024

	LItemInitIndex uint64 = 1<<32 - 512
)
View Source 
const (
	TSTRING byte = iota
	TLISTMETA
	TLISTDATA
	THASHMETA
	THASHDATA
	TSETMETA
	TSETDATA
	TZSETMETA
	TZSETSCORE
	TZSETDATA
	TTTLMETA
	TTTLDATA
)
View Source 
const (
	FNORMAL byte = iota
	FDELETED
)

Variables

View Source 
var (
	SCORE_MIN int64 = math.MinInt64 + 2
	SCORE_MAX int64 = math.MaxInt64 - 1
)
View Source 
var (
	EmptyListOrSet []interface{} = make([]interface{}, 0)
)

Functions

func HDataDecoder 

func HDataDecoder(rawkey []byte) ([]byte, []byte, error)

func HDataEncoder 

func HDataEncoder(key, field []byte) []byte

data key type(1)|keylen(2)|key|field

func HMetaDecoder 

func HMetaDecoder(rawkey []byte) ([]byte, error)

func HMetaEncoder 

func HMetaEncoder(key []byte) []byte

hash encoder decoder meta key type(1)|key

func LDataDecoder 

func LDataDecoder(rawkey []byte) ([]byte, uint64, error)

func LDataEncoder 

func LDataEncoder(key []byte, idx uint64) []byte

list data key type(1)|keylen(2)|key|index(8)

func LMetaDecoder 

func LMetaDecoder(rawkey []byte) ([]byte, error)

func LMetaEncoder 

func LMetaEncoder(key []byte) []byte

list list meta key

func NewTTLChecker 

func NewTTLChecker(datatype byte, max, interval int, tdb *Tidis) *ttlChecker

func SDataDecoder 

func SDataDecoder(rawkey []byte) ([]byte, []byte, error)

func SDataEncoder 

func SDataEncoder(key, member []byte) []byte

func SDecoder 

func SDecoder(rawkey []byte) ([]byte, error)

func SEncoder 

func SEncoder(key []byte) []byte

string type(1)|key

func SMetaDecoder 

func SMetaDecoder(rawkey []byte) ([]byte, error)

func SMetaEncoder 

func SMetaEncoder(key []byte) []byte

set encoder/decoder same as hash

func TDSDecoder 

func TDSDecoder(rawkey []byte) ([]byte, error)

func TDSEncoder 

func TDSEncoder(key []byte) []byte

for ttl get type(ttl)|type(key_type)|key, value is unix timestamp

func TMHDecoder 

func TMHDecoder(rawkey []byte) ([]byte, uint64, error)

func TMHEncoder 

func TMHEncoder(key []byte, ts uint64) []byte

for ttl checker type(ttl)|type(key_type)|timestamp(8)|key

func TMLDecoder 

func TMLDecoder(rawkey []byte) ([]byte, uint64, error)

func TMLEncoder 

func TMLEncoder(key []byte, ts uint64) []byte

for ttl checker type(ttl)|type(key_type)|timestamp(8)|key

func TMSDecoder 

func TMSDecoder(rawkey []byte) ([]byte, uint64, error)

func TMSEncoder 

func TMSEncoder(key []byte, ts uint64) []byte

for ttl checker type(ttl)|type(key_type)|timestamp(8)|key

func TMSetDecoder 

func TMSetDecoder(rawkey []byte) ([]byte, uint64, error)

func TMSetEncoder 

func TMSetEncoder(key []byte, ts uint64) []byte

for ttl checker type(ttl)|type(key_type)|timestamp(8)|key

func TMZDecoder 

func TMZDecoder(rawkey []byte) ([]byte, uint64, error)

func TMZEncoder 

func TMZEncoder(key []byte, ts uint64) []byte

for ttl checker type(ttl)|type(key_type)|timestamp(8)|key

func TTLExpired 

func TTLExpired(ttl int64) bool

check a ttl value is expired

func ZDataDecoder 

func ZDataDecoder(rawkey []byte) ([]byte, []byte, error)

func ZDataEncoder 

func ZDataEncoder(key, member []byte) []byte

type|len(key)|key|len(member)|member value: member score

func ZDataEncoderEnd 

func ZDataEncoderEnd(key []byte) []byte

func ZDataEncoderStart 

func ZDataEncoderStart(key []byte) []byte

func ZMetaDecoder 

func ZMetaDecoder(rawkey []byte) ([]byte, error)

func ZMetaEncoder 

func ZMetaEncoder(key []byte) []byte

sorted set type|key

func ZScoreDecoder 

func ZScoreDecoder(rawkey []byte) ([]byte, []byte, int64, error)

func ZScoreEncoder 

func ZScoreEncoder(key, member []byte, score int64) []byte

type|len(key)|key|score|member

func ZScoreOffset 

func ZScoreOffset(score int64) uint64

func ZScoreRestore 

func ZScoreRestore(rscore uint64) int64

Types

type AsyncDelItem 

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

type MemberPair 

type MemberPair struct {
	Score  int64
	Member []byte
}

type Tidis 

type Tidis struct {
	Lock sync.Mutex
	// contains filtered or unexported fields
}

func NewTidis 

func NewTidis(conf *config.Config) (*Tidis, error)

func (*Tidis) AsyncDelAdd 

func (tidis *Tidis) AsyncDelAdd(keyType byte, ukey []byte) error

func (*Tidis) AsyncDelDone 

func (tidis *Tidis) AsyncDelDone(keyType byte, ukey []byte) error

func (*Tidis) ClearExpire 

func (tidis *Tidis) ClearExpire(txn interface{}, key []byte) error

func (*Tidis) Close 

func (tidis *Tidis) Close() error

func (*Tidis) Decr 

func (tidis *Tidis) Decr(key []byte, step int64) (int64, error)

func (*Tidis) DecrWithTxn 

func (tidis *Tidis) DecrWithTxn(txn interface{}, key []byte, step int64) (int64, error)

func (*Tidis) Delete 

func (tidis *Tidis) Delete(txn interface{}, keys [][]byte) (int, error)

func (*Tidis) DeleteIfExpired 

func (tidis *Tidis) DeleteIfExpired(txn interface{}, key []byte) error

func (*Tidis) Expire 

func (tidis *Tidis) Expire(key []byte, s int64) (int, error)

func (*Tidis) ExpireAt 

func (tidis *Tidis) ExpireAt(key []byte, ts int64) (int, error)

func (*Tidis) ExpireAtWithTxn 

func (tidis *Tidis) ExpireAtWithTxn(txn interface{}, key []byte, ts int64) (int, error)

func (*Tidis) ExpireWithTxn 

func (tidis *Tidis) ExpireWithTxn(txn interface{}, key []byte, s int64) (int, error)

func (*Tidis) Get 

func (tidis *Tidis) Get(txn interface{}, key []byte) ([]byte, error)

func (*Tidis) HExpire 

func (tidis *Tidis) HExpire(key []byte, s int64) (int, error)

func (*Tidis) HExpireAt 

func (tidis *Tidis) HExpireAt(key []byte, ts int64) (int, error)

func (*Tidis) HExpireAtWithTxn 

func (tidis *Tidis) HExpireAtWithTxn(txn interface{}, key []byte, ts int64) (int, error)

func (*Tidis) HExpireWithTxn 

func (tidis *Tidis) HExpireWithTxn(txn interface{}, key []byte, s int64) (int, error)

func (*Tidis) HPExpire 

func (tidis *Tidis) HPExpire(key []byte, ms int64) (int, error)

func (*Tidis) HPExpireAt 

func (tidis *Tidis) HPExpireAt(key []byte, ts int64) (int, error)

func (*Tidis) HPExpireAtWithTxn 

func (tidis *Tidis) HPExpireAtWithTxn(txn interface{}, key []byte, ts int64) (int, error)

func (*Tidis) HPExpireWithTxn 

func (tidis *Tidis) HPExpireWithTxn(txn interface{}, key []byte, ms int64) (int, error)

func (*Tidis) HPTtl 

func (tidis *Tidis) HPTtl(txn interface{}, key []byte) (int64, error)

func (*Tidis) HTtl 

func (tidis *Tidis) HTtl(txn interface{}, key []byte) (int64, error)

func (*Tidis) Hclear 

func (tidis *Tidis) Hclear(key []byte, async bool) (uint8, error)

func (*Tidis) HclearExpire 

func (tidis *Tidis) HclearExpire(txn interface{}, key []byte) error

func (*Tidis) HclearWithTxn 

func (tidis *Tidis) HclearWithTxn(txn1 interface{}, key []byte, async *bool) (uint8, error)

func (*Tidis) Hdel 

func (tidis *Tidis) Hdel(key []byte, fields ...[]byte) (uint64, error)

func (*Tidis) HdelWithTxn 

func (tidis *Tidis) HdelWithTxn(txn interface{}, key []byte, fields ...[]byte) (uint64, error)

func (*Tidis) HdeleteIfExpired 

func (tidis *Tidis) HdeleteIfExpired(txn interface{}, key []byte) error

func (*Tidis) Hexists 

func (tidis *Tidis) Hexists(txn interface{}, key, field []byte) (bool, error)

func (*Tidis) Hget 

func (tidis *Tidis) Hget(txn interface{}, key, field []byte) ([]byte, error)

func (*Tidis) Hgetall 

func (tidis *Tidis) Hgetall(txn interface{}, key []byte) ([]interface{}, error)

func (*Tidis) Hkeys 

func (tidis *Tidis) Hkeys(txn interface{}, key []byte) ([]interface{}, error)

func (*Tidis) Hlen 

func (tidis *Tidis) Hlen(txn interface{}, key []byte) (uint64, error)

func (*Tidis) Hmget 

func (tidis *Tidis) Hmget(txn interface{}, key []byte, fields ...[]byte) ([]interface{}, error)

func (*Tidis) Hmset 

func (tidis *Tidis) Hmset(key []byte, fieldsvalues ...[]byte) error

func (*Tidis) HmsetWithTxn 

func (tidis *Tidis) HmsetWithTxn(txn interface{}, key []byte, fieldsvalues ...[]byte) error

func (*Tidis) Hset 

func (tidis *Tidis) Hset(key, field, value []byte) (uint8, error)

func (*Tidis) HsetWithTxn 

func (tidis *Tidis) HsetWithTxn(txn interface{}, key, field, value []byte) (uint8, error)

func (*Tidis) Hsetnx 

func (tidis *Tidis) Hsetnx(key, field, value []byte) (uint8, error)

func (*Tidis) HsetnxWithTxn 

func (tidis *Tidis) HsetnxWithTxn(txn interface{}, key, field, value []byte) (uint8, error)

func (*Tidis) Hstrlen 

func (tidis *Tidis) Hstrlen(txn interface{}, key, field []byte) (int, error)

func (*Tidis) Hvals 

func (tidis *Tidis) Hvals(txn interface{}, key []byte) ([]interface{}, error)

func (*Tidis) Incr 

func (tidis *Tidis) Incr(key []byte, step int64) (int64, error)

func (*Tidis) IncrWithTxn 

func (tidis *Tidis) IncrWithTxn(txn interface{}, key []byte, step int64) (int64, error)

func (*Tidis) LExpire 

func (tidis *Tidis) LExpire(key []byte, s int64) (int, error)

func (*Tidis) LExpireAt 

func (tidis *Tidis) LExpireAt(key []byte, ts int64) (int, error)

func (*Tidis) LExpireAtWithTxn 

func (tidis *Tidis) LExpireAtWithTxn(txn interface{}, key []byte, ts int64) (int, error)

func (*Tidis) LExpireWithTxn 

func (tidis *Tidis) LExpireWithTxn(txn interface{}, key []byte, s int64) (int, error)

func (*Tidis) LPExpire 

func (tidis *Tidis) LPExpire(key []byte, ms int64) (int, error)

func (*Tidis) LPExpireAt 

func (tidis *Tidis) LPExpireAt(key []byte, ts int64) (int, error)

func (*Tidis) LPExpireAtWithTxn 

func (tidis *Tidis) LPExpireAtWithTxn(txn interface{}, key []byte, ts int64) (int, error)

func (*Tidis) LPExpireWithTxn 

func (tidis *Tidis) LPExpireWithTxn(txn interface{}, key []byte, ms int64) (int, error)

func (*Tidis) LPTtl 

func (tidis *Tidis) LPTtl(txn interface{}, key []byte) (int64, error)

func (*Tidis) LTtl 

func (tidis *Tidis) LTtl(txn interface{}, key []byte) (int64, error)

func (*Tidis) LazyCheck 

func (tidis *Tidis) LazyCheck() bool

func (*Tidis) LclearExpire 

func (tidis *Tidis) LclearExpire(txn interface{}, key []byte) error

clear expire flag in meta and delete ttl key

func (*Tidis) LdelWithTxn 

func (tidis *Tidis) LdelWithTxn(txn1 interface{}, key []byte, async *bool) (int, error)

func (*Tidis) Ldelete 

func (tidis *Tidis) Ldelete(key []byte, async bool) (int, error)

func (*Tidis) LdeleteIfExpired 

func (tidis *Tidis) LdeleteIfExpired(txn interface{}, key []byte) error

func (*Tidis) Lindex 

func (tidis *Tidis) Lindex(txn interface{}, key []byte, index int64) ([]byte, error)

func (*Tidis) Llen 

func (tidis *Tidis) Llen(txn interface{}, key []byte) (uint64, error)

func (*Tidis) Lpop 

func (tidis *Tidis) Lpop(txn interface{}, key []byte) ([]byte, error)

func (*Tidis) Lpush 

func (tidis *Tidis) Lpush(txn interface{}, key []byte, items ...[]byte) (uint64, error)

func (*Tidis) Lrange 

func (tidis *Tidis) Lrange(txn interface{}, key []byte, start, stop int64) ([]interface{}, error)

return map[string][]byte key is encoded key, not user key

func (*Tidis) Lset 

func (tidis *Tidis) Lset(key []byte, index int64, value []byte) error

func (*Tidis) LsetWithTxn 

func (tidis *Tidis) LsetWithTxn(txn interface{}, key []byte, index int64, value []byte) error

func (*Tidis) Ltrim 

func (tidis *Tidis) Ltrim(key []byte, start, stop int64) error

func (*Tidis) LtrimWithTxn 

func (tidis *Tidis) LtrimWithTxn(txn interface{}, key []byte, start, stop int64) error

func (*Tidis) MGet 

func (tidis *Tidis) MGet(txn interface{}, keys [][]byte) ([]interface{}, error)

func (*Tidis) MSet 

func (tidis *Tidis) MSet(txn interface{}, keyvals [][]byte) (int, error)

func (*Tidis) NewTxn 

func (tidis *Tidis) NewTxn() (interface{}, error)

func (*Tidis) PExpire 

func (tidis *Tidis) PExpire(key []byte, ms int64) (int, error)

func (*Tidis) PExpireAt 

func (tidis *Tidis) PExpireAt(key []byte, ts int64) (int, error)

func (*Tidis) PExpireAtWithTxn 

func (tidis *Tidis) PExpireAtWithTxn(txn interface{}, key []byte, ts int64) (int, error)

func (*Tidis) PExpireWithTxn 

func (tidis *Tidis) PExpireWithTxn(txn interface{}, key []byte, ms int64) (int, error)

func (*Tidis) PTtl 

func (tidis *Tidis) PTtl(txn interface{}, key []byte) (int64, error)

func (*Tidis) Rpop 

func (tidis *Tidis) Rpop(txn interface{}, key []byte) ([]byte, error)

func (*Tidis) Rpush 

func (tidis *Tidis) Rpush(txn interface{}, key []byte, items ...[]byte) (uint64, error)

func (*Tidis) RunAsync 

func (tidis *Tidis) RunAsync()

func (*Tidis) SExpire 

func (tidis *Tidis) SExpire(key []byte, s int64) (int, error)

func (*Tidis) SExpireAt 

func (tidis *Tidis) SExpireAt(key []byte, ts int64) (int, error)

func (*Tidis) SExpireAtWithTxn 

func (tidis *Tidis) SExpireAtWithTxn(txn interface{}, key []byte, ts int64) (int, error)

func (*Tidis) SExpireWithTxn 

func (tidis *Tidis) SExpireWithTxn(txn interface{}, key []byte, s int64) (int, error)

func (*Tidis) SPExpire 

func (tidis *Tidis) SPExpire(key []byte, ms int64) (int, error)

func (*Tidis) SPExpireAt 

func (tidis *Tidis) SPExpireAt(key []byte, ts int64) (int, error)

func (*Tidis) SPExpireAtWithTxn 

func (tidis *Tidis) SPExpireAtWithTxn(txn interface{}, key []byte, ts int64) (int, error)

func (*Tidis) SPExpireWithTxn 

func (tidis *Tidis) SPExpireWithTxn(txn interface{}, key []byte, ms int64) (int, error)

func (*Tidis) SPTtl 

func (tidis *Tidis) SPTtl(txn interface{}, key []byte) (int64, error)

func (*Tidis) STtl 

func (tidis *Tidis) STtl(txn interface{}, key []byte) (int64, error)

func (*Tidis) Sadd 

func (tidis *Tidis) Sadd(key []byte, members ...[]byte) (uint64, error)

func (*Tidis) SaddWithTxn 

func (tidis *Tidis) SaddWithTxn(txn interface{}, key []byte, members ...[]byte) (uint64, error)

func (*Tidis) Scard 

func (tidis *Tidis) Scard(txn interface{}, key []byte) (uint64, error)

func (*Tidis) Sclear 

func (tidis *Tidis) Sclear(async bool, keys ...[]byte) (uint64, error)

func (*Tidis) SclearExpire 

func (tidis *Tidis) SclearExpire(txn interface{}, key []byte) error

func (*Tidis) SclearKeyWithTxn 

func (tidis *Tidis) SclearKeyWithTxn(txn1 interface{}, key []byte, async *bool, lazyCheckConstraint bool) (int, error)

func (*Tidis) SclearWithTxn 

func (tidis *Tidis) SclearWithTxn(async *bool, lazyCheckConstraint bool, txn interface{}, keys ...[]byte) (uint64, error)

func (*Tidis) SdeleteIfExpired 

func (tidis *Tidis) SdeleteIfExpired(txn interface{}, key []byte) error

func (*Tidis) Sdiff 

func (tidis *Tidis) Sdiff(txn interface{}, keys ...[]byte) ([]interface{}, error)

func (*Tidis) Sdiffstore 

func (tidis *Tidis) Sdiffstore(dest []byte, keys ...[]byte) (uint64, error)

func (*Tidis) SdiffstoreWithTxn 

func (tidis *Tidis) SdiffstoreWithTxn(txn interface{}, dest []byte, keys ...[]byte) (uint64, error)

func (*Tidis) Set 

func (tidis *Tidis) Set(txn interface{}, key, value []byte) error

func (*Tidis) SetWithParam 

func (tidis *Tidis) SetWithParam(txn interface{}, key, value []byte, msTtl int64, nxFlag bool, xxFlag bool) (bool, error)

func (*Tidis) Setex 

func (tidis *Tidis) Setex(key []byte, sec int64, value []byte) error

func (*Tidis) SetexWithTxn 

func (tidis *Tidis) SetexWithTxn(txn interface{}, key []byte, sec int64, value []byte) error

func (*Tidis) Sinter 

func (tidis *Tidis) Sinter(txn interface{}, keys ...[]byte) ([]interface{}, error)

func (*Tidis) Sinterstore 

func (tidis *Tidis) Sinterstore(dest []byte, keys ...[]byte) (uint64, error)

func (*Tidis) SinterstoreWithTxn 

func (tidis *Tidis) SinterstoreWithTxn(txn interface{}, dest []byte, keys ...[]byte) (uint64, error)

func (*Tidis) Sismember 

func (tidis *Tidis) Sismember(txn interface{}, key, member []byte) (uint8, error)

func (*Tidis) Smembers 

func (tidis *Tidis) Smembers(txn interface{}, key []byte) ([]interface{}, error)

func (*Tidis) Sops 

func (tidis *Tidis) Sops(txn interface{}, opType int, keys ...[]byte) ([]interface{}, error)

func (*Tidis) SopsStore 

func (tidis *Tidis) SopsStore(opType int, dest []byte, keys ...[]byte) (uint64, error)

func (*Tidis) SopsStoreWithTxn 

func (tidis *Tidis) SopsStoreWithTxn(txn interface{}, opType int, dest []byte, keys ...[]byte) (uint64, error)

func (*Tidis) Srem 

func (tidis *Tidis) Srem(key []byte, members ...[]byte) (uint64, error)

func (*Tidis) SremWithTxn 

func (tidis *Tidis) SremWithTxn(txn interface{}, key []byte, members ...[]byte) (uint64, error)

func (*Tidis) Sunion 

func (tidis *Tidis) Sunion(txn interface{}, keys ...[]byte) ([]interface{}, error)

func (*Tidis) Sunionstore 

func (tidis *Tidis) Sunionstore(dest []byte, keys ...[]byte) (uint64, error)

func (*Tidis) SunionstoreWithTxn 

func (tidis *Tidis) SunionstoreWithTxn(txn interface{}, dest []byte, keys ...[]byte) (uint64, error)

func (*Tidis) Ttl 

func (tidis *Tidis) Ttl(txn interface{}, key []byte) (int64, error)

func (*Tidis) ZExpire 

func (tidis *Tidis) ZExpire(key []byte, s int64) (int, error)

func (*Tidis) ZExpireAt 

func (tidis *Tidis) ZExpireAt(key []byte, ts int64) (int, error)

func (*Tidis) ZExpireAtWithTxn 

func (tidis *Tidis) ZExpireAtWithTxn(txn interface{}, key []byte, ts int64) (int, error)

func (*Tidis) ZExpireWithTxn 

func (tidis *Tidis) ZExpireWithTxn(txn interface{}, key []byte, s int64) (int, error)

func (*Tidis) ZPExpire 

func (tidis *Tidis) ZPExpire(key []byte, ms int64) (int, error)

func (*Tidis) ZPExpireAt 

func (tidis *Tidis) ZPExpireAt(key []byte, ts int64) (int, error)

func (*Tidis) ZPExpireAtWithTxn 

func (tidis *Tidis) ZPExpireAtWithTxn(txn interface{}, key []byte, ts int64) (int, error)

func (*Tidis) ZPExpireWithTxn 

func (tidis *Tidis) ZPExpireWithTxn(txn interface{}, key []byte, ms int64) (int, error)

func (*Tidis) ZPTtl 

func (tidis *Tidis) ZPTtl(txn interface{}, key []byte) (int64, error)

func (*Tidis) ZTtl 

func (tidis *Tidis) ZTtl(txn interface{}, key []byte) (int64, error)

func (*Tidis) Zadd 

func (tidis *Tidis) Zadd(key []byte, mps ...*MemberPair) (int, error)

func (*Tidis) ZaddWithTxn 

func (tidis *Tidis) ZaddWithTxn(txn interface{}, key []byte, mps ...*MemberPair) (int, error)

func (*Tidis) Zcard 

func (tidis *Tidis) Zcard(txn interface{}, key []byte) (uint64, error)

func (*Tidis) Zcount 

func (tidis *Tidis) Zcount(txn interface{}, key []byte, min, max int64) (uint64, error)

func (*Tidis) Zincrby 

func (tidis *Tidis) Zincrby(key []byte, delta int64, member []byte) (int64, error)

func (*Tidis) ZincrbyWithTxn 

func (tidis *Tidis) ZincrbyWithTxn(txn interface{}, key []byte, delta int64, member []byte) (int64, error)

func (*Tidis) Zlexcount 

func (tidis *Tidis) Zlexcount(txn interface{}, key, start, stop []byte) (uint64, error)

func (*Tidis) Zrange 

func (tidis *Tidis) Zrange(txn interface{}, key []byte, start, stop int64, withscores bool, reverse bool) ([]interface{}, error)

func (*Tidis) Zrangebylex 

func (tidis *Tidis) Zrangebylex(txn interface{}, key []byte, start, stop []byte, offset, count int, reverse bool) ([]interface{}, error)

func (*Tidis) Zrangebyscore 

func (tidis *Tidis) Zrangebyscore(txn interface{}, key []byte, min, max int64, withscores bool, offset, count int, reverse bool) ([]interface{}, error)

func (*Tidis) Zrank 

func (tidis *Tidis) Zrank(txn interface{}, key, member []byte, score int64) (int64, bool, error)

func (*Tidis) Zrem 

func (tidis *Tidis) Zrem(key []byte, members ...[]byte) (uint64, error)

func (*Tidis) ZremWithTxn 

func (tidis *Tidis) ZremWithTxn(txn interface{}, key []byte, members ...[]byte) (uint64, error)

func (*Tidis) Zremrangebylex 

func (tidis *Tidis) Zremrangebylex(key, start, stop []byte) (uint64, error)

func (*Tidis) ZremrangebylexWithTxn 

func (tidis *Tidis) ZremrangebylexWithTxn(txn interface{}, key, start, stop []byte) (uint64, error)

func (*Tidis) Zremrangebyscore 

func (tidis *Tidis) Zremrangebyscore(key []byte, min, max int64, async bool) (uint64, error)

func (*Tidis) ZremrangebyscoreWithTxn 

func (tidis *Tidis) ZremrangebyscoreWithTxn(txn1 interface{}, key []byte, min, max int64, async *bool) (uint64, error)

func (*Tidis) Zscore 

func (tidis *Tidis) Zscore(txn interface{}, key, member []byte) (int64, bool, 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.