From 9fc3a1b44a64ceaf8feb83c9ed558b751fbe7e5a Mon Sep 17 00:00:00 2001 From: c9s Date: Wed, 4 Sep 2024 16:09:58 +0800 Subject: [PATCH] xmaker: rename to aggTradeVolume --- pkg/strategy/xmaker/signal_trade.go | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/pkg/strategy/xmaker/signal_trade.go b/pkg/strategy/xmaker/signal_trade.go index bb3db5f9c..876cb3090 100644 --- a/pkg/strategy/xmaker/signal_trade.go +++ b/pkg/strategy/xmaker/signal_trade.go @@ -75,7 +75,7 @@ func (s *TradeVolumeWindowSignal) filterTrades(now time.Time) []types.Trade { return trades } -func (s *TradeVolumeWindowSignal) calculateTradeVolume(trades []types.Trade) (buyVolume, sellVolume float64) { +func (s *TradeVolumeWindowSignal) aggTradeVolume(trades []types.Trade) (buyVolume, sellVolume float64) { for _, td := range trades { if td.IsBuyer { buyVolume += td.Quantity.Float64() @@ -87,10 +87,10 @@ func (s *TradeVolumeWindowSignal) calculateTradeVolume(trades []types.Trade) (bu return buyVolume, sellVolume } -func (s *TradeVolumeWindowSignal) CalculateSignal(ctx context.Context) (float64, error) { +func (s *TradeVolumeWindowSignal) CalculateSignal(_ context.Context) (float64, error) { now := time.Now() trades := s.filterTrades(now) - buyVolume, sellVolume := s.calculateTradeVolume(trades) + buyVolume, sellVolume := s.aggTradeVolume(trades) totalVolume := buyVolume + sellVolume threshold := s.Threshold.Float64()