Merge pull request #98 from pinguo-yangbing/master

redis

adapter/interface.go

@@ -98,6 +98,7 @@ type IRedis interface {
 	MDel(keys []string) bool
 	Exists(key string) bool
 	Incr(key string, delta int) int
+	IncrBy(key string, delta int) (int, error)
 	Do(cmd string, args ...interface{}) interface{}
 	ExpireAt(key string, timestamp int64) bool
 	Expire(key string, expire time.Duration) bool
@@ -113,7 +114,7 @@ type IRedis interface {
 	HGetAll(key string) map[string]*value.Value
 	HMSet(key string, fv ...interface{}) bool
 	HMGet(key string, fields ...interface{}) map[string]*value.Value
-	HIncrBy(key, field string, delta int) int
+	HIncrBy(key, field string, delta int) (int,error)
 	ZRange(key string, start, end int) []*value.Value
 	ZRevRange(key string, start, end int) []*value.Value
 	ZRangeWithScores(key string, start, end int) []*redis.ZV

adapter/redis.go

@@ -205,6 +205,18 @@ func (r *Redis) Incr(key string, delta int) int {
 	return res
 }
 
+func (r *Redis) IncrBy(key string, delta int) (int, error) {
+	profile := "Redis.IncrBy"
+	r.Context().ProfileStart(profile)
+	defer r.Context().ProfileStop(profile)
+	defer r.handlePanic()
+
+	res, err := r.client.Incr(key, delta)
+	r.parseErr(err)
+
+	return res,err
+}
+
 // 支持的命令请查阅：Redis.allRedisCmd
 // args = [0:"key"]
 // Example:
@@ -424,7 +436,7 @@ func (r *Redis) HMGet(key string,fields ...interface{}) map[string]*value.Value
 	return res
 }
 
-func (r *Redis) HIncrBy(key, field string, delta int) int {
+func (r *Redis) HIncrBy(key, field string, delta int) (int,error) {
 	profile := "Redis.HIncrBy"
 	r.Context().ProfileStart(profile)
 	defer r.Context().ProfileStop(profile)
@@ -433,7 +445,7 @@ func (r *Redis) HIncrBy(key, field string, delta int) int {
 	res, err := r.client.HIncrBy(key,field, delta)
 	r.parseErr(err)
 
-	return res
+	return res,err
 }
 
 func (r *Redis) ZRange(key string, start, end int) []*value.Value {