func()

in hub/hub.go [361:375]


func (f *familyAndMetrics) addMetrics(newMetrics []*dto.Metric) {
	// Keep array sorted [t0, t1, t2...] each insert
	for _, metric := range newMetrics {
		metricName := makeLabeledName(metric, f.family.GetName())
		if queue, ok := f.metrics[metricName]; ok {
			if *metric.TimestampMs >= *queue[len(queue)-1].TimestampMs {
				f.metrics[metricName] = append(queue, metric)
			} else {
				f.metrics[metricName] = sortedInsert(queue, metric)
			}
		} else {
			f.metrics[metricName] = []*dto.Metric{metric}
		}
	}
}