Method Decode

pkg/ruler/frontend_decoder.go:35–73

(body []byte)

}

func (j JsonDecoder) Decode(body []byte) (promql.Vector, Warnings, error) {
	var response api.Response

	if err := json.NewDecoder(bytes.NewReader(body)).Decode(&response); err != nil {
		return nil, nil, err
	}
	if response.Status == statusError {
		return nil, response.Warnings, fmt.Errorf("failed to execute query with error: %s", response.Error)
	}
	data := struct {
		Type   model.ValueType `json:"resultType"`
		Result json.RawMessage `json:"result"`
	}{}

	if responseDataBytes, err := json.Marshal(response.Data); err != nil {
		return nil, response.Warnings, err
	} else {
		if err = json.Unmarshal(responseDataBytes, &data); err != nil {
			return nil, response.Warnings, err
		}
	}

	switch data.Type {
	case model.ValScalar:
		var scalar model.Scalar
		if err := json.Unmarshal(data.Result, &scalar); err != nil {
			return nil, nil, err
		}
		return scalarToPromQLVector(scalar), response.Warnings, nil
	case model.ValVector:
		var vector model.Vector
		if err := json.Unmarshal(data.Result, &vector); err != nil {
			return nil, nil, err
		}
		return j.vectorToPromQLVector(vector), response.Warnings, nil
	default:
		return nil, response.Warnings, errors.New("rule result is not a vector or scalar")
	}
}

func (j JsonDecoder) vectorToPromQLVector(vector model.Vector) promql.Vector {
	v := make([]promql.Sample, 0, len(vector))