lychiyu/bbgo_origin
1
0
Fork 0
mirror of https://github.com/c9s/bbgo.git synced 2024-11-22 14:55:16 +00:00
Code Issues Actions 2 Packages Projects Releases Wiki Activity

merge used intervals

Browse Source
This commit is contained in:
c9s 2022-05-20 00:50:58 +08:00
parent ec2f0cd0b1
commit 369afa8ab1
No known key found for this signature in database
GPG Key ID: 7385E7E464CB0A54
1 changed files with 6 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
pkg/cmd/backtest.go
View File

@ -462,14 +462,17 @@ var BacktestCmd = &cobra.Command{
} }
allKLineIntervals := map[types.Interval]struct{}{} allKLineIntervals := map[types.Interval]struct{}{}
for _, interval := range backTestIntervals {
allKLineIntervals[interval] = struct{}{}
}
for _, session := range environ.Sessions() { for _, session := range environ.Sessions() {
for _, sub := range session.Subscriptions { for _, sub := range session.Subscriptions {
if sub.Channel == types.KLineChannel { if sub.Channel == types.KLineChannel {
allKLineIntervals[types.Interval(sub.Options.Interval)] = struct{}{} allKLineIntervals[sub.Options.Interval] = struct{}{}
} }
} }
} }
for interval := range allKLineIntervals { for interval := range allKLineIntervals {
summaryReport.Intervals = append(summaryReport.Intervals, interval) summaryReport.Intervals = append(summaryReport.Intervals, interval)
} }
@ -583,7 +586,7 @@ func createSymbolReport(userConfig *bbgo.Config, session *bbgo.ExchangeSession,
sessionKLineIntervals := map[types.Interval]struct{}{} sessionKLineIntervals := map[types.Interval]struct{}{}
for _, sub := range session.Subscriptions { for _, sub := range session.Subscriptions {
if sub.Channel == types.KLineChannel { if sub.Channel == types.KLineChannel {
sessionKLineIntervals[types.Interval(sub.Options.Interval)] = struct{}{} sessionKLineIntervals[sub.Options.Interval] = struct{}{}
} }
} }