Function newCollectingAppender

pkg/util/push/appender.go:29–34

newCollectingAppender returns a new collectingAppender that implements prometheusremotewrite.CombinedAppender and accumulates all appended data for later retrieval via TimeSeries() and Metadata().

()

// prometheusremotewrite.CombinedAppender and accumulates all appended data
// for later retrieval via TimeSeries() and Metadata().
func newCollectingAppender() *collectingAppender {
	return &collectingAppender{
		series:   make(map[string]*collectedSeries),
		metadata: make(map[string]prompb.MetricMetadata),
	}
}

func (c *collectingAppender) AppendSample(ls labels.Labels, meta prometheusremotewrite.Metadata, ct, t int64, v float64, es []exemplar.Exemplar) error {
	c.recordMetadata(meta)