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}
}
}
}