Skip to content

Commit

Permalink
add more dynamic metrics
Browse files Browse the repository at this point in the history
  • Loading branch information
c9s committed Dec 18, 2024
1 parent 19ace1f commit 5cf9a3a
Show file tree
Hide file tree
Showing 2 changed files with 11 additions and 1 deletion.
6 changes: 6 additions & 0 deletions pkg/strategy/scmaker/strategy.go
Original file line number Diff line number Diff line change
Expand Up @@ -9,6 +9,7 @@ import (
log "github.com/sirupsen/logrus"

"github.com/c9s/bbgo/pkg/bbgo"
"github.com/c9s/bbgo/pkg/dynamic"
"github.com/c9s/bbgo/pkg/fixedpoint"
. "github.com/c9s/bbgo/pkg/indicator/v2"
"github.com/c9s/bbgo/pkg/strategy/common"
Expand Down Expand Up @@ -122,6 +123,11 @@ func (s *Strategy) Run(ctx context.Context, _ bbgo.OrderExecutor, session *bbgo.

s.liquidityScale = scale

instanceID := s.InstanceID()
if err := dynamic.InitializeConfigMetrics(ID, instanceID, s); err != nil {
return err
}

s.initializeMidPriceEMA(session)
s.initializePriceRangeBollinger(session)
s.initializeIntensityIndicator(session)
Expand Down
6 changes: 5 additions & 1 deletion pkg/strategy/xalign/strategy.go
Original file line number Diff line number Diff line change
Expand Up @@ -14,6 +14,7 @@ import (

"github.com/c9s/bbgo/pkg/bbgo"
"github.com/c9s/bbgo/pkg/core"
"github.com/c9s/bbgo/pkg/dynamic"
"github.com/c9s/bbgo/pkg/fixedpoint"
"github.com/c9s/bbgo/pkg/pricesolver"
"github.com/c9s/bbgo/pkg/slack/slackalert"
Expand Down Expand Up @@ -439,12 +440,15 @@ func (s *Strategy) selectSessionForCurrency(

func (s *Strategy) CrossRun(ctx context.Context, _ bbgo.OrderExecutionRouter, sessions map[string]*bbgo.ExchangeSession) error {
instanceID := s.InstanceID()
_ = instanceID

s.sessions = make(map[string]*bbgo.ExchangeSession)
s.orderBooks = make(map[string]*bbgo.ActiveOrderBook)
s.orderStore = core.NewOrderStore("")

if err := dynamic.InitializeConfigMetrics(ID, instanceID, s); err != nil {
return err
}

for currency, expectedValue := range s.ExpectedBalances {
s.deviationDetectors[currency] = detector.NewDeviationDetector(
types.Balance{Currency: currency, NetAsset: expectedValue}, // Expected value
Expand Down

0 comments on commit 5cf9a3a

Please sign in to comment.