INNER CODE UNIT · Go

tik

Edgio/vflow · consumers/clickhouse/main.go:104

			tik := time.Tick(10 * time.Second)

			for {
				select {
				case <-tik:
					if opts.Debug {
						log.Printf("partition GroupId#%d,  rate=%d\n", ti, (count-pCount)/10)
					}
					pCount = count
				case msg, more := <-consumer.Messages():
					objmap := ipfix{}
					if more {
						if err := json.Unmarshal(msg.Value, &objmap); err != nil {
							log.Println(err)
						} else {
							ch <- objmap
						}
						consumer.MarkOffset(msg, "")

View source record →