binance: change rate limit unit to minute

c9s · c9s · commit bf87d04d57de · 2022-12-22T19:07:55.000+08:00
diff --git a/pkg/exchange/binance/exchange.go b/pkg/exchange/binance/exchange.go
@@ -56,11 +56,11 @@ func init() {
 	_ = types.FuturesExchange(&Exchange{})
 
 	if n, ok := util.GetEnvVarInt("BINANCE_ORDER_RATE_LIMITER"); ok {
-		orderLimiter = rate.NewLimiter(rate.Limit(n), 2)
+		orderLimiter = rate.NewLimiter(rate.Every(time.Duration(n)*time.Minute), 2)
 	}
 
 	if n, ok := util.GetEnvVarInt("BINANCE_QUERY_TRADES_RATE_LIMITER"); ok {
-		queryTradeLimiter = rate.NewLimiter(rate.Limit(n), 2)
+		queryTradeLimiter = rate.NewLimiter(rate.Every(time.Duration(n)*time.Minute), 2)
 	}
 }
 

Original file line number	Diff line number	Diff line change
`@@ -56,11 +56,11 @@ func init() {`
`56`	`56`	`_ = types.FuturesExchange(&Exchange{})`
`57`	`57`
`58`	`58`	`if n, ok := util.GetEnvVarInt("BINANCE_ORDER_RATE_LIMITER"); ok {`
`59`		`- orderLimiter = rate.NewLimiter(rate.Limit(n), 2)`
	`59`	`+ orderLimiter = rate.NewLimiter(rate.Every(time.Duration(n)*time.Minute), 2)`
`60`	`60`	`}`
`61`	`61`
`62`	`62`	`if n, ok := util.GetEnvVarInt("BINANCE_QUERY_TRADES_RATE_LIMITER"); ok {`
`63`		`- queryTradeLimiter = rate.NewLimiter(rate.Limit(n), 2)`
	`63`	`+ queryTradeLimiter = rate.NewLimiter(rate.Every(time.Duration(n)*time.Minute), 2)`
`64`	`64`	`}`
`65`	`65`	`}`
`66`	`66`