Function makeWriteRequestWithNHCB

pkg/distributor/distributor_test.go:3450–3490

makeWriteRequestWithNHCB builds a write request with optional NHCB (native histogram custom buckets) timeseries.

(startTimestampMs int64, samples int, metadata int, histograms int, nhcb int)

// makeWriteRequestWithNHCB builds a write request with optional NHCB (native histogram custom buckets) timeseries.
func makeWriteRequestWithNHCB(startTimestampMs int64, samples int, metadata int, histograms int, nhcb int) *cortexpb.WriteRequest {
	request := &cortexpb.WriteRequest{}
	for i := range samples {
		request.Timeseries = append(request.Timeseries, makeWriteRequestTimeseries(
			[]cortexpb.LabelAdapter{
				{Name: model.MetricNameLabel, Value: "foo"},
				{Name: "bar", Value: "baz"},
				{Name: "sample", Value: fmt.Sprintf("%d", i)},
			}, startTimestampMs+int64(i), int64(i), false))
	}

	for i := range histograms {
		request.Timeseries = append(request.Timeseries, makeWriteRequestTimeseries(
			[]cortexpb.LabelAdapter{
				{Name: model.MetricNameLabel, Value: "foo"},
				{Name: "bar", Value: "baz"},
				{Name: "histogram", Value: fmt.Sprintf("%d", i)},
			}, startTimestampMs+int64(i), int64(i), true))
	}

	for i := range nhcb {
		ts := startTimestampMs + int64(i)
		request.Timeseries = append(request.Timeseries, makeWriteRequestTimeseriesNHCB(
			[]cortexpb.LabelAdapter{
				{Name: model.MetricNameLabel, Value: "foo"},
				{Name: "bar", Value: "baz"},
				{Name: "nhcb", Value: fmt.Sprintf("%d", i)},
			}, ts, int64(i)))
	}

	for i := range metadata {
		m := &cortexpb.MetricMetadata{
			MetricFamilyName: fmt.Sprintf("metric_%d", i),
			Type:             cortexpb.COUNTER,
			Help:             fmt.Sprintf("a help for metric_%d", i),
		}
		request.Metadata = append(request.Metadata, m)
	}

	return request
}

func makeWriteRequestTimeseries(labels []cortexpb.LabelAdapter, ts, value int64, histogram bool) cortexpb.PreallocTimeseries {
	t := cortexpb.PreallocTimeseries{