goAndChannle.go

func RecordAlertHistory(q *Queue, ah *AlertHistory) {

	q.PushQueue(ah)

	c := make(chan int)
	currentQueueLen := q.GetQueueLength()
	beego.Debug("Get Queue Len AAA: ", currentQueueLen)

	wg.Add(2)
	go func() {
		defer wg.Done()
		c <- currentQueueLen
	}()

	// 每隔1分钟，或者队列中的数据达到1000条，将数据批量写入influxdb
	go func() {
		defer wg.Done()
		ticker := time.NewTicker(DEFAULTINTERVAL)
		defer ticker.Stop()
		for {
			select {
			case t := <-ticker.C:
				func() {
					beego.Debug("ticker... ", t)
					writeToInfluxDB(currentQueueLen, q)
				}()
			case length := <-c:
				func() {
					beego.Debug("Get Queue Len... ", length)
					if length == MAX_LENGTH {
						writeToInfluxDB(length, q)
					}
				}()
			}
		}
	}()

	wg.Wait()

}