lychiyu/bbgo_origin
1
0
Fork 0
mirror of https://github.com/c9s/bbgo.git synced 2024-11-10 09:11:55 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

max: move submitOrderLimiter to the exchange wide var

Browse Source
This commit is contained in:
c9s 2023-03-21 16:25:16 +08:00
parent b48f9701fb
commit fda4e48146
No known key found for this signature in database
GPG Key ID: 7385E7E464CB0A54
1 changed files with 5 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
pkg/exchange/max/exchange.go
View File

@ -25,7 +25,6 @@ var closedOrderQueryLimiter = rate.NewLimiter(rate.Every(1*time.Second), 1)
var tradeQueryLimiter = rate.NewLimiter(rate.Every(3*time.Second), 1)
var accountQueryLimiter = rate.NewLimiter(rate.Every(3*time.Second), 1)
var marketDataLimiter = rate.NewLimiter(rate.Every(2*time.Second), 10)
var submitOrderLimiter = rate.NewLimiter(rate.Every(300*time.Millisecond), 10)
var log = logrus.WithField("exchange", "max")
@ -37,6 +36,8 @@ type Exchange struct {
v3order *v3.OrderService
v3margin *v3.MarginService
submitOrderLimiter *rate.Limiter
}
func New(key, secret string) *Exchange {
@ -54,6 +55,8 @@ func New(key, secret string) *Exchange {
secret: secret,
v3order: &v3.OrderService{Client: client},
v3margin: &v3.MarginService{Client: client},
submitOrderLimiter: rate.NewLimiter(rate.Every(100*time.Millisecond), 10),
}
}
@ -452,7 +455,7 @@ func (e *Exchange) Withdraw(ctx context.Context, asset string, amount fixedpoint
}
func (e *Exchange) SubmitOrder(ctx context.Context, order types.SubmitOrder) (createdOrder *types.Order, err error) {
if err := submitOrderLimiter.Wait(ctx); err != nil {
if err := e.submitOrderLimiter.Wait(ctx); err != nil {
return nil, err
}