(lbls labels.Labels, samples []cortexpb.Sample)
| 4046 | } |
| 4047 | |
| 4048 | func writeRequestSingleSeries(lbls labels.Labels, samples []cortexpb.Sample) *cortexpb.WriteRequest { |
| 4049 | req := &cortexpb.WriteRequest{ |
| 4050 | Source: cortexpb.API, |
| 4051 | } |
| 4052 | |
| 4053 | ts := cortexpb.TimeSeries{} |
| 4054 | ts.Labels = cortexpb.FromLabelsToLabelAdapters(lbls) |
| 4055 | ts.Samples = samples |
| 4056 | req.Timeseries = append(req.Timeseries, cortexpb.PreallocTimeseries{TimeSeries: &ts}) |
| 4057 | |
| 4058 | return req |
| 4059 | } |
| 4060 | |
| 4061 | type mockMetricsForLabelMatchersStreamServer struct { |
| 4062 | grpc.ServerStream |
no test coverage detected