com

func Cron ¶

func Cron() *cron.Cron

func DelPairCopieds ¶

func DelPairCopieds(keys ...string)

func EnsureLatestPrice ¶ added in v0.2.33

func EnsureLatestPrice(symbol string) *errs.Error

EnsureLatestPrice makes sure the cached price is valid (not expired) for the symbol. It only fetches from exchange when the cache is invalid.

func GetBookTickers ¶ added in v0.2.33

func GetBookTickers() (map[string]*banexg.Ticker, *errs.Error)

GetBookTickers fetches latest book tickers and updates the price cache.

func GetPairCopieds ¶

func GetPairCopieds() map[string][2]int64

func GetPrice ¶

func GetPrice(symbol string, side string) float64

GetPrice panic if price expired or not found

func GetPriceExp ¶

func GetPriceExp(symbol string, side string, expMS int64) float64

GetPriceExp panic if price expired before expMS or not found

func GetPriceSafe ¶

func GetPriceSafe(symbol string, side string) float64

GetPriceSafe return -1 if price expired or not found

func GetPriceSafeExp ¶

func GetPriceSafeExp(symbol string, side string, expMS int64) float64

func IsMaker ¶

func IsMaker(pair, side string, price float64) bool

func IsPriceEmpty ¶

func IsPriceEmpty() bool

func RefreshLatestPrice ¶ added in v0.2.33

func RefreshLatestPrice(symbol string) *errs.Error

RefreshLatestPrice forces a price refresh when called outside bar-complete flow. It respects a short throttle window and returns nil if a valid cached price exists.

func SetBarPrice ¶

func SetBarPrice(pair string, price float64)

func SetPairCopieds ¶

func SetPairCopieds(items map[string][2]int64)

func SetPairMs ¶

func SetPairMs(pair string, barMS, waitMS int64)

SetPairMs update LastBarMs/wait interval from spider 更新bot端从爬虫收到的标的最新时间和等待间隔

func SetPrice ¶

func SetPrice(pair string, ask, bid float64)

func SetPrices ¶

func SetPrices(data map[string]float64, side string)