Skip to content

Commit

Permalink
change metric prefix
Browse files Browse the repository at this point in the history
  • Loading branch information
patrickmann committed Nov 15, 2024
1 parent b226780 commit 1d091c7
Showing 1 changed file with 2 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -203,7 +203,7 @@ private IndexingFailure fromIndexingError(IndexingError indexingError) {
private void updateProcessingFailureMetric(Message message) {
Object inputId = message.getField(FIELD_GL2_SOURCE_INPUT);
if (inputId != null) {
final String indexingFailureMetricName = name("org.graylog2", inputId.toString(), "failures.processing");
final String indexingFailureMetricName = name("org.graylog2.inputs", inputId.toString(), "failures.processing");
metricRegistry.meter(indexingFailureMetricName).mark();
}
}
Expand All @@ -212,7 +212,7 @@ private void updateIndexingFailureMetric(Indexable message) {
final Map<String, Object> searchObject = message.toElasticSearchObject(objectMapper, dummyMeter);
Object inputId = searchObject.get(FIELD_GL2_SOURCE_INPUT);
if (inputId != null) {
final String indexingFailureMetricName = name("org.graylog2", inputId.toString(), "failures.indexing");
final String indexingFailureMetricName = name("org.graylog2.inputs", inputId.toString(), "failures.indexing");
metricRegistry.meter(indexingFailureMetricName).mark();
}
}
Expand Down

0 comments on commit 1d091c7

Please sign in to comment.