Method Decode

pkg/ruler/frontend_decoder.go:95–126

(body []byte)

}

func (p ProtobufDecoder) Decode(body []byte) (promql.Vector, Warnings, error) {
	resp := tripperware.PrometheusResponse{}
	if err := resp.Unmarshal(body); err != nil {
		return nil, nil, err
	}

	if resp.Status == statusError {
		return nil, resp.Warnings, fmt.Errorf("failed to execute query with error: %s", resp.Error)
	}

	switch resp.Data.ResultType {
	case "scalar":
		data := struct {
			Type   model.ValueType `json:"resultType"`
			Result json.RawMessage `json:"result"`
		}{}

		if err := json.Unmarshal(resp.Data.Result.GetRawBytes(), &data); err != nil {
			return nil, nil, err
		}

		var s model.Scalar
		if err := json.Unmarshal(data.Result, &s); err != nil {
			return nil, nil, err
		}
		return scalarToPromQLVector(s), resp.Warnings, nil
	case "vector":
		return p.vectorToPromQLVector(resp.Data.Result.GetVector()), resp.Warnings, nil
	default:
		return nil, resp.Warnings, errors.New("rule result is not a vector or scalar")
	}
}

func (p ProtobufDecoder) vectorToPromQLVector(vector *tripperware.Vector) promql.Vector {
	v := make([]promql.Sample, 0, len(vector.Samples))