func processFamilyWorker()

in hub/hub.go [250:261]

• 12 lines of code
• 3 McCabe index (conditional complexity)

func processFamilyWorker(fams <-chan *familyAndMetrics, results chan<- string, waitGroup *sync.WaitGroup) {
	defer waitGroup.Done()
	for fam := range fams {
		pullFamily := fam.popDatapoints()
		familyStr, err := familyToString(pullFamily)
		if err != nil {
			log.Printf("metric %s dropped. error converting metric to string: %v", *pullFamily.Name, err)
		} else {
			results <- familyStr
		}
	}
}