Method prepare

server/controller/prometheus/label.go:209–225

(toEncode *dataToEncode)

}

func (s *LabelSynchronizer) prepare(toEncode *dataToEncode) error {
	if toEncode.cardinality() == 0 {
		return nil
	}

	syncResp, err := s.grpcurl.Sync(s.generateSyncRequest(toEncode))
	if err != nil {
		return errors.Wrap(err, "grpcurl.Sync")
	}
	eg := &errgroup.Group{}
	common.AppendErrGroup(eg, s.addMetricNameCache, syncResp.GetMetricNames())
	common.AppendErrGroup(eg, s.addLabelNameCache, syncResp.GetLabelNames())
	common.AppendErrGroup(eg, s.addLabelValueCache, syncResp.GetLabelValues())
	common.AppendErrGroup(eg, s.addMetricAPPLabelLayoutCache, syncResp.GetMetricAppLabelLayouts())
	common.AppendErrGroup(eg, s.addLabelCache, syncResp.GetLabels())
	return eg.Wait()
}

func (s *LabelSynchronizer) splitData(req *trident.PrometheusLabelRequest) *dataToEncode {
	toEncode := newDataToEncode(s.cache)