Skip to content

Commit 1b325bc

Browse files
committed
Create new reason on the discarted sample metric - native histogram
1 parent 7e37e92 commit 1b325bc

File tree

7 files changed

+2098
-147
lines changed

7 files changed

+2098
-147
lines changed

pkg/cortexpb/compat.go

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -21,7 +21,7 @@ import (
2121

2222
// ToWriteRequest converts matched slices of Labels, Samples and Metadata into a WriteRequest proto.
2323
// It gets timeseries from the pool, so ReuseSlice() should be called when done.
24-
func ToWriteRequest(lbls []labels.Labels, samples []Sample, metadata []*MetricMetadata, source WriteRequest_SourceEnum) *WriteRequest {
24+
func ToWriteRequest(lbls []labels.Labels, samples []Sample, metadata []*MetricMetadata, histograms []Histogram, source WriteRequest_SourceEnum) *WriteRequest {
2525
req := &WriteRequest{
2626
Timeseries: PreallocTimeseriesSliceFromPool(),
2727
Metadata: metadata,
@@ -32,6 +32,9 @@ func ToWriteRequest(lbls []labels.Labels, samples []Sample, metadata []*MetricMe
3232
ts := TimeseriesFromPool()
3333
ts.Labels = append(ts.Labels, FromLabelsToLabelAdapters(lbls[i])...)
3434
ts.Samples = append(ts.Samples, s)
35+
if i < len(histograms) {
36+
ts.Histograms = append(ts.Histograms, histograms[i])
37+
}
3538
req.Timeseries = append(req.Timeseries, PreallocTimeseries{TimeSeries: ts})
3639
}
3740

0 commit comments

Comments
 (0)