INNER CODE UNIT · Go

WsBookTicker

aleibovici/cryptopump · algorithms/algorithms.go:710

func WsBookTicker(
	viperData *types.ViperData,
	configData *types.Config,
	marketData *types.Market,
	sessionData *types.Session,
	wg *sync.WaitGroup) {

	var doneC chan struct{}
	var stopC chan struct{}
	var err error

	wsHandler := &types.WsHandler{}
	wsHandler.BinanceWsBookTicker = func(event *binance.WsBookTickerEvent) {

		/* Record requests-per-second increment used with github.com/paulbellamy/ratecounter */
		sessionData.RateCounter.Incr(1)

		/* This session variable stores the time of the last WsBookTicker used for status check */

View source record →