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

pkg/exchange: use backoff retry

Browse Source
This commit is contained in:
Edwin 2023-11-21 17:59:25 +08:00
parent 51718b6eb2
commit 87d763598f
1 changed files with 2 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
pkg/exchange/bybit/stream.go
View File

@ -11,9 +11,9 @@ import (
"golang.org/x/time/rate" "golang.org/x/time/rate"
"github.com/c9s/bbgo/pkg/exchange/bybit/bybitapi" "github.com/c9s/bbgo/pkg/exchange/bybit/bybitapi"
"github.com/c9s/bbgo/pkg/exchange/retry"
"github.com/c9s/bbgo/pkg/fixedpoint" "github.com/c9s/bbgo/pkg/fixedpoint"
"github.com/c9s/bbgo/pkg/types" "github.com/c9s/bbgo/pkg/types"
"github.com/c9s/bbgo/pkg/util"
) )
const ( const (
@ -351,11 +351,9 @@ func (s *Stream) handleAuthEvent() {
var balnacesMap types.BalanceMap var balnacesMap types.BalanceMap
var err error var err error
err = util.Retry(ctx, 10, 300*time.Millisecond, func() error { err = retry.GeneralBackoff(ctx, func() error {
balnacesMap, err = s.streamDataProvider.QueryAccountBalances(ctx) balnacesMap, err = s.streamDataProvider.QueryAccountBalances(ctx)
return err return err
}, func(err error) {
log.WithError(err).Error("failed to call query account balances")
}) })
if err != nil { if err != nil {
log.WithError(err).Error("no more attempts to retrieve balances") log.WithError(err).Error("no more attempts to retrieve balances")