INNER CODE UNIT · Go

candleDuration

sklinkert/at · cmd/import-histdata/main.go:77

	const candleDuration = time.Minute * 1
	for currentTick := range c {
		if candle != nil {
			isOpen := candle.NewPrice(currentTick.Price(), currentTick.Datetime)
			if !isOpen {
				if err := tx.Create(candle).Error; err != nil {
					fatal("Cannot store candle", err)
				}
				candle = nil // force new candle opening
			}
		}
		if candle == nil {
			candle = ohlc.New(instrument, currentTick.Datetime, candleDuration, true)
			candle.NewPrice(currentTick.Price(), currentTick.Datetime)
		}
		//if err := tx.Create(&currentTick).Error; err != nil {
		//	log.WithError(err).Warn("db.Create() failed: %v", currentTick)
		//	continue

View source record →