Versions Compared

Key

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

...

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

	public CommitMetrics() {
		this.group = new MetricsGroup(GROUP_NAME);
	}
	private void registerCommitMetrics() {   
		group.gauge(LAST_COMMIT_DURATION_METRIC, new CommitDurationGauge());
		...
	}
}

...

Code Block
public class ScanMetrics {
	private final String GROUP_NAME = "scanMetricGroup";
	private final String LAST_SCAN_SKIPPED_MANIFESTS_METRIC = "lastScanSkippedManifests";
	...
 	private MetricGroup group;

	public ScanMetrics() {
		this.group = new MetricsGroup(GROUP_NAME);
	}
   	
	private void registerScanMetrics() {   
		group.gauge(LAST_SCAN_SKIPPED_MANIFESTS_METRIC, new LastScanSkippedManifestsGauge());
		...
	}
}

...

Code Block
public class CompactionMetrics {

 	private final String GROUP_NAME = "compactionMetricGroup";
	private final String LAST_TABLE_FILES_COMPACTED_BEFORE_METRIC = "lastTableFilesCompactedBefore";
 	...
 	private MetricGroup group;

	public CompactionMetrics() {
		this.group = new MetricsGroup(GROUP_NAME);
	}
   	
	private void registerScanMetrics() {   
		group.gauge(LAST_TABLE_FILES_COMPACTED_BEFORE_METRIC, new LastTableFilesCompactedBeforeGauge());
		...
	} 
}

...