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

add accessor to MarketDataStore

Browse Source
This commit is contained in:
c9s 2020-10-18 12:27:11 +08:00
parent 7d7828a556
commit 168cb355fc
2 changed files with 15 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
pkg/bbgo/environment.go
View File

@ -102,7 +102,7 @@ func (environ *Environment) Init(ctx context.Context) (err error) {
session.LastPrices[symbol] = currentPrice
session.MarketDataStores[symbol] = store.NewMarketDataStore(symbol)
session.marketDataStores[symbol] = store.NewMarketDataStore(symbol)
}
log.Infof("querying balances...")
@ -121,7 +121,7 @@ func (environ *Environment) Init(ctx context.Context) (err error) {
// update last prices
stream.OnKLineClosed(func(kline types.KLine) {
session.LastPrices[kline.Symbol] = kline.Close
session.MarketDataStores[kline.Symbol].AddKLine(kline)
session.marketDataStores[kline.Symbol].AddKLine(kline)
})
stream.OnTrade(func(trade *types.Trade) {

9
pkg/bbgo/session.go
View File

@ -30,7 +30,7 @@ type ExchangeSession struct {
// map: symbol -> []trade
Trades map[string][]types.Trade
MarketDataStores map[string]*store.MarketDataStore
marketDataStores map[string]*store.MarketDataStore
}
func NewExchangeSession(name string, exchange types.Exchange) *ExchangeSession {
@ -41,10 +41,15 @@ func NewExchangeSession(name string, exchange types.Exchange) *ExchangeSession {
Markets: make(map[string]types.Market),
Trades: make(map[string][]types.Trade),
LastPrices: make(map[string]float64),
MarketDataStores: make(map[string]*store.MarketDataStore),
marketDataStores: make(map[string]*store.MarketDataStore),
}
}
func (session *ExchangeSession) MarketDataStore(symbol string) (s *store.MarketDataStore, ok bool) {
s, ok = session.marketDataStores[symbol]
return s, ok
}
// Subscribe save the subscription info, later it will be assigned to the stream
func (session *ExchangeSession) Subscribe(channel types.Channel, symbol string, options types.SubscribeOptions) *ExchangeSession {
sub := types.Subscription{