INNER CODE UNIT · Go

WsKline

aleibovici/cryptopump · algorithms/algorithms.go:609

func WsKline(
	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.BinanceWsKline = func(event *binance.WsKlineEvent) {

		/* This session variable stores the time of the last WsKline used for status check */
		sessionData.LastWsKlineTime = time.Now()

		/* Stop Ws channel */
		if sessionData.StopWs {

View source record →