INNER CODE UNIT · Go

pollingTicker

groundcover-com/caretta · pkg/caretta/caretta.go:73

	pollingTicker := time.NewTicker(time.Duration(caretta.config.pollingIntervalSeconds) * time.Second)

	pastLinks := make(map[NetworkLink]uint64)

	go func() {
		for {
			select {
			case <-caretta.stopSignal:
				return
			case <-pollingTicker.C:
				var links map[NetworkLink]uint64
				var tcpConnections []TcpConnection

				if err != nil {
					log.Printf("Error updating snapshot of cluster state, skipping iteration")
					continue
				}

View source record →