Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

Code Block
languagejava
public class CommitMetrics {
	private final String COMMIT_DURATION_METRIC = "lastCommitDuration";
	...
	private MetricGroup group;

	public CommitMetrics() {
		String gruopName = "commitMetricGroup";
		this.group = new MetricsGroup(gruopName);
  		 getMetricsInstance().addGroup(gruopName, group);
	}
	private void registerCommitMetrics() {   
		group.gauge(COMMIT_DURATION_METRIC, new CommitDurationTimer());
		...
	}
}

...

Code Block
public class ScanMetrics {
	private final String SCAN_FILES_METRIC = "lastScanDuration";
	...
 	private MetricGroup group;

	public ScanMetrics() {
		String gruopName = "scanMetricGroup";
		this.group = new MetricsGroup(gruopName);
  		 getMetricsInstance().addGroup(gruopName, group);
	}
   	
	private void registerScanMetrics() {   
		group.counter(SCAN_FILES_METRIC, new ScanFilesCounter());
		...
	}
}

...

Code Block
public class CompactionMetrics {

 	private final String COMPACTED_FILES_METRIC = "lastCompactionDuration";
 	...
 	private MetricGroup group;

	public CompactionMetrics() {
		String gruopName = "compactionMetricGroup";
		this.group = new MetricsGroup(gruopName);
  		 getMetricsInstance().addGroup(gruopName, group);
	}
   	
	private void registerScanMetrics() {   
		group.counter(COMPACTED_FILES_METRIC, new CompactedFilesCounter());
		...
	} 
}

...