mirror of
https://github.com/duanhf2012/origin.git
synced 2026-02-04 06:54:45 +08:00
ZREM
This commit is contained in:
@@ -1312,6 +1312,30 @@ func (slf *RedisModule) ZREMRANGEBYSCORE(key string, start, stop interface{}) er
|
|||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func (slf *RedisModule) ZREM(key string, member interface{}) (int, error) {
|
||||||
|
conn, err := slf.getConn()
|
||||||
|
if err != nil {
|
||||||
|
return 0, err
|
||||||
|
}
|
||||||
|
defer conn.Close()
|
||||||
|
|
||||||
|
reply, err := conn.Do("ZREM", key, member)
|
||||||
|
return redis.Int(reply, err)
|
||||||
|
}
|
||||||
|
|
||||||
|
func (slf *RedisModule) ZREMMulti(key string, member ...interface{}) (int, error) {
|
||||||
|
conn, err := slf.getConn()
|
||||||
|
if err != nil {
|
||||||
|
return 0, err
|
||||||
|
}
|
||||||
|
defer conn.Close()
|
||||||
|
|
||||||
|
args := []interface{}{key}
|
||||||
|
args = append(args, member...)
|
||||||
|
reply, err := conn.Do("ZREM", args...)
|
||||||
|
return redis.Int(reply, err)
|
||||||
|
}
|
||||||
|
|
||||||
func (slf *RedisModule) LRangeJSON(key string, start, stop int, data interface{}) error {
|
func (slf *RedisModule) LRangeJSON(key string, start, stop int, data interface{}) error {
|
||||||
b, err := slf.LRange(key, start, stop)
|
b, err := slf.LRange(key, start, stop)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
|
|||||||
Reference in New Issue
Block a user