| 44 | } |
| 45 | |
| 46 | func (c *collectingAppender) AppendHistogram(ls labels.Labels, meta prometheusremotewrite.Metadata, ct, t int64, h *histogram.Histogram, es []exemplar.Exemplar) error { |
| 47 | if h == nil { |
| 48 | return nil |
| 49 | } |
| 50 | c.recordMetadata(meta) |
| 51 | s := c.getOrCreateSeries(ls) |
| 52 | s.histograms = append(s.histograms, prompb.FromIntHistogram(t, h)) |
| 53 | for _, e := range es { |
| 54 | s.exemplars = append(s.exemplars, exemplarToProm(e)) |
| 55 | } |
| 56 | return nil |
| 57 | } |
| 58 | |
| 59 | func (c *collectingAppender) recordMetadata(meta prometheusremotewrite.Metadata) { |
| 60 | key := meta.MetricFamilyName |