mirror of
https://github.com/c9s/bbgo.git
synced 2024-11-25 16:25:16 +00:00
bbgo: rename AddBackLog to BackFill
This commit is contained in:
parent
064932ea9d
commit
9885a68537
|
@ -38,7 +38,7 @@ func (i *IndicatorSet) KLines(interval types.Interval) *indicator.KLineStream {
|
||||||
|
|
||||||
kLines := indicator.KLines(i.stream, i.Symbol, interval)
|
kLines := indicator.KLines(i.stream, i.Symbol, interval)
|
||||||
if kLinesWindow, ok := i.store.KLinesOfInterval(interval); ok {
|
if kLinesWindow, ok := i.store.KLinesOfInterval(interval); ok {
|
||||||
kLines.AddBackLog(*kLinesWindow)
|
kLines.BackFill(*kLinesWindow)
|
||||||
} else {
|
} else {
|
||||||
logrus.Warnf("market data store %s kline history not found, unable to backfill the kline stream data", interval)
|
logrus.Warnf("market data store %s kline history not found, unable to backfill the kline stream data", interval)
|
||||||
}
|
}
|
||||||
|
|
|
@ -36,7 +36,7 @@ func (s *KLineStream) AddSubscriber(f func(k types.KLine)) {
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
func (s *KLineStream) AddBackLog(kLines []types.KLine) {
|
func (s *KLineStream) BackFill(kLines []types.KLine) {
|
||||||
s.kLines = append(s.kLines, kLines...)
|
s.kLines = append(s.kLines, kLines...)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue
Block a user