mirror of
https://github.com/c9s/bbgo.git
synced 2024-11-10 09:11:55 +00:00
Compare commits
2 Commits
f12ba1adb9
...
7d034d1ba8
Author | SHA1 | Date | |
---|---|---|---|
|
7d034d1ba8 | ||
|
7135895006 |
|
@ -51,6 +51,13 @@ func (q *Quota) Rollback() {
|
|||
q.mu.Unlock()
|
||||
}
|
||||
|
||||
func (q *Quota) String() string {
|
||||
q.mu.Lock()
|
||||
defer q.mu.Unlock()
|
||||
|
||||
return q.Locked.String() + "/" + q.Available.String()
|
||||
}
|
||||
|
||||
// QuotaTransaction is a transactional quota manager
|
||||
type QuotaTransaction struct {
|
||||
mu sync.Mutex
|
||||
|
|
|
@ -624,12 +624,14 @@ func (s *Strategy) updateQuote(ctx context.Context) {
|
|||
if s.MaxExposurePosition.Sign() > 0 {
|
||||
pos := s.Position.GetBase()
|
||||
|
||||
if pos.Compare(s.MaxExposurePosition.Neg()) > 0 {
|
||||
if pos.Compare(s.MaxExposurePosition.Neg()) <= 0 {
|
||||
// stop sell if we over-sell
|
||||
disableMakerAsk = true
|
||||
} else if pos.Compare(s.MaxExposurePosition) > 0 {
|
||||
s.logger.Warnf("%s ask maker is disabled: %f exceeded max exposure %f", s.Symbol, pos.Float64(), s.MaxExposurePosition.Float64())
|
||||
} else if pos.Compare(s.MaxExposurePosition) >= 0 {
|
||||
// stop buy if we over buy
|
||||
disableMakerBid = true
|
||||
s.logger.Warnf("%s bid maker is disabled: %f exceeded max exposure %f", s.Symbol, pos.Float64(), s.MaxExposurePosition.Float64())
|
||||
}
|
||||
}
|
||||
|
||||
|
|
Loading…
Reference in New Issue
Block a user