[gobblin] branch master updated: Register gauge metrics for change monitors (#3634)

[wlo]

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 <umus...@gmail.com>
AuthorDate: Thu Feb 2 08:23:53 2023 -0800

    Register gauge metrics for change monitors (#3634)
    
    Co-authored-by: Urmi Mustafi <umust...@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