Versions in this module Expand all Collapse all v1 v1.5.0 Jun 21, 2018 Changes in this version + const FourHour + const GMCLock + const GlobalMarketTickerKey + const GlobalTickerKey + const GlobalTrendKey + const OneDay + const OneHour + const OneWeek + const TwoHour + type BinanceTicker struct + Amount string + Ask string + Bid string + Change string + Close string + High string + LastPrice string + Low string + Open string + Symbol string + Vol string + type Cache struct + Fills []dao.FillEvent + Trends []Trend + type Collector interface + Start func() + type CollectorImpl struct + func NewCollector() *CollectorImpl + func (c *CollectorImpl) GetTickers(market string) ([]Ticker, error) + func (c *CollectorImpl) Start() + type Exchange interface + type ExchangeImpl struct + func NewExchange(name, tickerUrl string) ExchangeImpl + type ExchangeType string + type GlobalMarket struct + var GM *GlobalMarket + func NewGlobalMarket(config MyTokenConfig) GlobalMarket + func (g *GlobalMarket) GetGlobalMarketTicker(symbol string) (trend []GlobalMarketTicker, err error) + func (g *GlobalMarket) GetGlobalMarketTickerCache(token string) (tickers map[string][]GlobalMarketTicker, err error) + func (g *GlobalMarket) GetGlobalTicker(token string) (ticker GlobalTicker, err error) + func (g *GlobalMarket) GetGlobalTickerCache(token string) (tickers map[string]GlobalTicker, err error) + func (g *GlobalMarket) GetGlobalTrend(token string) (trend []GlobalTrend, err error) + func (g *GlobalMarket) GetGlobalTrendCache(token string) (trends map[string][]GlobalTrend, err error) + func (g *GlobalMarket) Sign(param interface{}) (urlParam string, err error) + func (g *GlobalMarket) Start() + type GlobalMarketTicker struct + Alias string + Anchor string + MarketName string + Pair string + PercentChangeUtc0 string + Price string + PriceCny string + PriceUsd string + Symbol string + Volume24h string + Volume24hFrom string + Volume24hUsd string + type GlobalMarketTickerReq struct + Anchor string + NameId string + SortField string + SortType string + Symbol string + type GlobalMarketTickerResp struct + Data map[string][]GlobalMarketTicker + type GlobalTicker struct + Alias string + PercentChangeUtc0 string + Price string + PriceCny string + PriceCnyUtc0 string + PriceUpdatedAt string + PriceUsd string + Symbol string + Volume24h string + Volume24hFrom string + Volume24hUsd string + type GlobalTickerReq struct + NameId string + type GlobalTickerResp struct + Data GlobalTicker + type GlobalTrend struct + Price string + Time string + VolumeFrom string + type GlobalTrendReq struct + Limit int64 + NameId string + Period string + TrendAnchor string + type GlobalTrendResp struct + Data map[string][]GlobalTrend + type HuobiInnerTicker struct + Amount float64 + Ask []float64 + Bid []float64 + Close float64 + Count int + High float64 + Low float64 + Open float64 + Vol float64 + type HuobiTicker struct + ErrorCode string + Status string + Tick HuobiInnerTicker + Timestamp int64 + type MyTokenConfig struct + AppId string + AppSecret string + BaseUrl string + type MyTokenResp struct + Code int + Message string + Timestamp int64 + type OkexFullTicker struct + Code int + Data []OkexTickerElem + Msg string + type OkexInnerTicker struct + Ask string + Bid string + High string + LastPrice string + Low string + Vol string + type OkexTicker struct + Date string + Ticker OkexInnerTicker + type OkexTickerElem struct + Buy string + Change string + High string + Last string + Low string + Symbol string + Vol string + type Ticker struct + Amount float64 + Buy float64 + Change string + Close float64 + Exchange string + High float64 + Intervals string + Last float64 + Low float64 + Market string + Open float64 + Sell float64 + Vol float64 + func GetAllTickerFromBinance() (tickers []Ticker, err error) + func GetAllTickerFromOkex() (tickers []Ticker, err error) + func GetTickerFromBinance(market string) (ticker Ticker, err error) + func GetTickerFromHuobi(market string) (ticker Ticker, err error) + func GetTickerFromOkex(market string) (ticker Ticker, err error) + type TickerField struct + type Trend struct + Amount float64 + Close float64 + CreateTime int64 + End int64 + High float64 + Intervals string + Low float64 + Market string + Open float64 + Start int64 + Vol float64 + func ConvertUp(src dao.Trend) Trend + type TrendManager struct + func NewTrendManager(dao *dao.RdsService) TrendManager + func (t *TrendManager) GetTicker() (tickers []Ticker, err error) + func (t *TrendManager) GetTickerByMarket(mkt string) (ticker Ticker, err error) + func (t *TrendManager) GetTrends(market, interval string) (trends []Trend, err error) + func (t *TrendManager) HandleOrderFilled(input eventemitter.EventData) (err error) + func (t *TrendManager) LoadCache() + func (t *TrendManager) ProofRead() + func (t *TrendManager) ScheduleUpdate() + type TrendUpdateMsg struct + Interval string + Market string