INNER CODE UNIT · Go

tik

Edgio/vflow · consumers/cli/main.go:92

			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():
					if more {
						if err := json.Unmarshal(msg.Value, &objmap); err != nil {
							log.Println(err)
						} else {
							for _, data := range objmap.DataSets {
								for _, dd := range data {
									if dd.I == opts.Id && dd.V == opts.Value {
										log.Printf("%#v\n", data)

View source record →