(vector *tripperware.Vector)
| 126 | } |
| 127 | |
| 128 | func (p ProtobufDecoder) vectorToPromQLVector(vector *tripperware.Vector) promql.Vector { |
| 129 | v := make([]promql.Sample, 0, len(vector.Samples)) |
| 130 | for _, sample := range vector.Samples { |
| 131 | metric := cortexpb.FromLabelAdaptersToLabels(sample.Labels) |
| 132 | |
| 133 | if sample.Sample != nil { |
| 134 | v = append(v, promql.Sample{ |
| 135 | T: sample.Sample.TimestampMs, |
| 136 | F: sample.Sample.Value, |
| 137 | Metric: metric, |
| 138 | }) |
| 139 | } |
| 140 | |
| 141 | if sample.RawHistogram != nil { |
| 142 | v = append(v, promql.Sample{ |
| 143 | T: sample.RawHistogram.TimestampMs, |
| 144 | H: cortexpb.FloatHistogramProtoToFloatHistogram(*sample.RawHistogram), |
| 145 | Metric: metric, |
| 146 | }) |
| 147 | } |
| 148 | } |
| 149 | |
| 150 | return v |
| 151 | } |
| 152 | |
| 153 | func scalarToPromQLVector(s model.Scalar) promql.Vector { |
| 154 | return promql.Vector{promql.Sample{ |
no test coverage detected