You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@gobblin.apache.org by wl...@apache.org on 2023/02/02 16:24:00 UTC
[gobblin] branch master updated: Register gauge metrics for change monitors (#3634)
This is an automated email from the ASF dual-hosted git repository.
wlo pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/gobblin.git
The following commit(s) were added to refs/heads/master by this push:
new 9f8ab24c8 Register gauge metrics for change monitors (#3634)
9f8ab24c8 is described below
commit 9f8ab24c8cf4bc195d23ebac0448a07ce2f91e2f
Author: umustafi <um...@gmail.com>
AuthorDate: Thu Feb 2 08:23:53 2023 -0800
Register gauge metrics for change monitors (#3634)
Co-authored-by: Urmi Mustafi <um...@umustafi-mn1.linkedin.biz>
---
.../apache/gobblin/service/monitoring/DagActionStoreChangeMonitor.java | 1 +
.../org/apache/gobblin/service/monitoring/SpecStoreChangeMonitor.java | 1 +
2 files changed, 2 insertions(+)
diff --git a/gobblin-service/src/main/java/org/apache/gobblin/service/monitoring/DagActionStoreChangeMonitor.java b/gobblin-service/src/main/java/org/apache/gobblin/service/monitoring/DagActionStoreChangeMonitor.java
index a42a01e23..732697038 100644
--- a/gobblin-service/src/main/java/org/apache/gobblin/service/monitoring/DagActionStoreChangeMonitor.java
+++ b/gobblin-service/src/main/java/org/apache/gobblin/service/monitoring/DagActionStoreChangeMonitor.java
@@ -185,6 +185,7 @@ public class DagActionStoreChangeMonitor extends HighLevelConsumer {
this.unexpectedErrors = this.getMetricContext().contextAwareMeter(RuntimeMetrics.GOBBLIN_DAG_ACTION_STORE_MONITOR_UNEXPECTED_ERRORS);
this.messageProcessedMeter = this.getMetricContext().contextAwareMeter(RuntimeMetrics.GOBBLIN_DAG_ACTION_STORE_MONITOR_MESSAGE_PROCESSED);
this.produceToConsumeDelayMillis = this.getMetricContext().newContextAwareGauge(RuntimeMetrics.GOBBLIN_DAG_ACTION_STORE_PRODUCE_TO_CONSUME_DELAY_MILLIS, () -> produceToConsumeDelayValue);
+ this.getMetricContext().register(this.produceToConsumeDelayMillis);
}
}
diff --git a/gobblin-service/src/main/java/org/apache/gobblin/service/monitoring/SpecStoreChangeMonitor.java b/gobblin-service/src/main/java/org/apache/gobblin/service/monitoring/SpecStoreChangeMonitor.java
index 4f7ac6e86..f029c08c6 100644
--- a/gobblin-service/src/main/java/org/apache/gobblin/service/monitoring/SpecStoreChangeMonitor.java
+++ b/gobblin-service/src/main/java/org/apache/gobblin/service/monitoring/SpecStoreChangeMonitor.java
@@ -180,5 +180,6 @@ public class SpecStoreChangeMonitor extends HighLevelConsumer {
this.unexpectedErrors = this.getMetricContext().contextAwareMeter(RuntimeMetrics.GOBBLIN_SPEC_STORE_MONITOR_UNEXPECTED_ERRORS);
this.messageProcessedMeter = this.getMetricContext().contextAwareMeter(RuntimeMetrics.GOBBLIN_SPEC_STORE_MESSAGE_PROCESSED);
this.produceToConsumeDelayMillis = this.getMetricContext().newContextAwareGauge(RuntimeMetrics.GOBBLIN_SPEC_STORE_PRODUCE_TO_CONSUME_DELAY_MILLIS, () -> produceToConsumeDelayValue);
+ this.getMetricContext().register(this.produceToConsumeDelayMillis);
}
}
\ No newline at end of file