(req *trident.PrometheusLabelRequest)
| 184 | } |
| 185 | |
| 186 | func (s *LabelSynchronizer) assemble(req *trident.PrometheusLabelRequest) (*trident.PrometheusLabelResponse, error) { |
| 187 | toEncode := s.splitData(req) |
| 188 | |
| 189 | err := s.prepare(toEncode) |
| 190 | if err != nil { |
| 191 | log.Errorf("prepare error: %+v", err, s.org.LogPrefix) |
| 192 | return nil, err |
| 193 | } |
| 194 | |
| 195 | resp := new(trident.PrometheusLabelResponse) |
| 196 | mls, err := s.assembleMetricLabel(req.GetRequestLabels()) |
| 197 | if err != nil { |
| 198 | return nil, errors.Wrap(err, "assembleMetricLabel") |
| 199 | } |
| 200 | resp.ResponseLabelIds = mls |
| 201 | return resp, nil |
| 202 | } |
| 203 | |
| 204 | func (s *LabelSynchronizer) setStatsdCounter() { |
| 205 | s.statsdCounter.SendMetricCount = s.counter.SendMetricCount |
no test coverage detected