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

pull out fillStrategyNotifiability

Browse Source
This commit is contained in:
c9s 2020-10-27 19:37:11 +08:00
parent ccc381143d
commit 7905ba09d4
1 changed files with 19 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

32
pkg/bbgo/trader.go
View File

@ -133,19 +133,7 @@ func (trader *Trader) Run(ctx context.Context) error {
// get the struct element // get the struct element
rs = rs.Elem() rs = rs.Elem()
field := rs.FieldByName("Notifiability") trader.fillStrategyNotifiability(strategy, rs)
if field.IsValid() {
log.Infof("found Notifiability in strategy %T, configuring...", strategy)
if !field.CanSet() {
log.Panicf("strategy %T field Notifiability can not be set", strategy)
}
if field.Type() == reflect.PtrTo(reflect.TypeOf(trader.Notifiability)) {
field.Set(reflect.ValueOf(&trader.Notifiability))
} else {
field.Set(reflect.ValueOf(trader.Notifiability))
}
}
} }
err := strategy.Run(ctx, orderExecutor, session) err := strategy.Run(ctx, orderExecutor, session)
@ -170,6 +158,24 @@ func (trader *Trader) Run(ctx context.Context) error {
return trader.environment.Connect(ctx) return trader.environment.Connect(ctx)
} }
func (trader *Trader) fillStrategyNotifiability(strategy SingleExchangeStrategy, rs reflect.Value) {
field := rs.FieldByName("Notifiability")
if !field.IsValid() {
return
}
log.Infof("found Notifiability in strategy %T, configuring...", strategy)
if !field.CanSet() {
log.Panicf("strategy %T field Notifiability can not be set", strategy)
}
if field.Type() == reflect.PtrTo(reflect.TypeOf(trader.Notifiability)) {
field.Set(reflect.ValueOf(&trader.Notifiability))
} else {
field.Set(reflect.ValueOf(trader.Notifiability))
}
}
/* /*
func (trader *OrderExecutor) RunStrategyWithHotReload(ctx context.Context, strategy SingleExchangeStrategy, configFile string) (chan struct{}, error) { func (trader *OrderExecutor) RunStrategyWithHotReload(ctx context.Context, strategy SingleExchangeStrategy, configFile string) (chan struct{}, error) {
var done = make(chan struct{}) var done = make(chan struct{})