Method Encode

server/controller/prometheus/encoder/encoder.go:79–94

(req *controller.SyncPrometheusRequest)

}

func (e *Encoder) Encode(req *controller.SyncPrometheusRequest) (*controller.SyncPrometheusResponse, error) {
	resp := new(controller.SyncPrometheusResponse)
	eg1RunAhead := &errgroup.Group{}
	common.AppendErrGroup(eg1RunAhead, e.encodeMetricName, resp, req.GetMetricNames())
	common.AppendErrGroup(eg1RunAhead, e.encodeLabelName, resp, req.GetLabelNames())
	common.AppendErrGroup(eg1RunAhead, e.encodeLabelValue, resp, req.GetLabelValues())
	err := eg1RunAhead.Wait()
	if err != nil {
		return resp, err
	}
	eg2RunAhead := &errgroup.Group{}
	common.AppendErrGroup(eg2RunAhead, e.encodeLabel, resp, req.GetLabels())
	common.AppendErrGroup(eg2RunAhead, e.encodeLabelIndex, resp, req.GetMetricAppLabelLayouts())
	err = eg2RunAhead.Wait()
	return resp, err
}

func (e *Encoder) encodeMetricName(args ...interface{}) error {
	resp := args[0].(*controller.SyncPrometheusResponse)