| 73 | } |
| 74 | |
| 75 | func (j JsonDecoder) vectorToPromQLVector(vector model.Vector) promql.Vector { |
| 76 | v := make([]promql.Sample, 0, len(vector)) |
| 77 | for _, sample := range vector { |
| 78 | builder := labels.NewBuilder(labels.EmptyLabels()) |
| 79 | for k, v := range sample.Metric { |
| 80 | builder.Set(string(k), string(v)) |
| 81 | } |
| 82 | v = append(v, promql.Sample{ |
| 83 | T: int64(sample.Timestamp), |
| 84 | F: float64(sample.Value), |
| 85 | Metric: builder.Labels(), |
| 86 | }) |
| 87 | } |
| 88 | return v |
| 89 | } |
| 90 | |
| 91 | func (p ProtobufDecoder) ContentType() string { |
| 92 | return tripperware.QueryResponseCortexMIMEType |