Remove error output of rateLimiter

Tons of useless output generated
journeymidnight · Apr 24, 2020 · 941d20e · 941d20e
1 parent be7d045
commit 941d20e
Show file tree

Hide file tree

Showing 2 changed files with 1 addition and 4 deletions.
diff --git a/go.mod b/go.mod
@@ -33,7 +33,7 @@ require (
 	github.com/confluentinc/confluent-kafka-go v1.0.0 //ct
 	github.com/dgrijalva/jwt-go v3.2.0+incompatible
 	github.com/dustin/go-humanize v1.0.0
-	github.com/go-redis/redis/v7 v7.0.0-beta.4
+	github.com/go-redis/redis/v7 v7.2.0
 	github.com/go-redis/redis_rate/v8 v8.0.0
 	github.com/go-sql-driver/mysql v1.4.1
 	github.com/golang/snappy v0.0.1

diff --git a/meta/qos.go b/meta/qos.go
@@ -53,7 +53,6 @@ func (m *QosMeta) AllowReadQuery(bucketName string) (allow bool) {
 	// the key actually used in redis would have a prefix "rate:"
 	result, err := m.rateLimiter.Allow(key, redis_rate.PerSecond(qps))
 	if err != nil {
-		helper.Logger.Error("AllowReadQuery:", err)
 		return true
 	}
 	return result.Allowed
@@ -69,7 +68,6 @@ func (m *QosMeta) AllowWriteQuery(bucketName string) (allow bool) {
 	// the key actually used in redis would have a prefix "rate:"
 	result, err := m.rateLimiter.Allow(key, redis_rate.PerSecond(qps))
 	if err != nil {
-		helper.Logger.Error("AllowWriteQuery:", err)
 		return true
 	}
 	return result.Allowed
@@ -154,7 +152,6 @@ func (t *throttler) maybeWaitTokenN(n int) {
 		result, err := t.rateLimiter.AllowN(key,
 			redis_rate.PerSecond(t.kbpsLimit*1024), n)
 		if err != nil {
-			helper.Logger.Error("ThrottleReader:", err)
 			return
 		}
 		if result.Allowed {