root
/
kafka
mirror of https://github.com/apache/kafka.git
1
0
Fork 0
Code Issues Actions 2 Packages Projects Releases Wiki Activity

MINOR: Remove redundant access specifiers from metrics interfaces (#6527) 

Reviewers: Sönke Liebau <soenke.liebau@opencore.com>, Ismael Juma <ismael@juma.me.uk>
This commit is contained in:
highluck 2019-04-09 18:20:37 +09:00 committed by Ismael Juma
parent 97bca4d3f5
commit 0667fe2bfd
3 changed files with 7 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
clients/src/main/java/org/apache/kafka/common/metrics/CompoundStat.java
View File

@ -26,9 +26,9 @@ import java.util.List;
*/ */
public interface CompoundStat extends Stat { public interface CompoundStat extends Stat {
public List<NamedMeasurable> stats(); List<NamedMeasurable> stats();
public static class NamedMeasurable { class NamedMeasurable {
private final MetricName name; private final MetricName name;
private final Measurable stat; private final Measurable stat;

8
clients/src/main/java/org/apache/kafka/common/metrics/MetricsReporter.java
View File

@ -31,23 +31,23 @@ public interface MetricsReporter extends Configurable, AutoCloseable {
* This is called when the reporter is first registered to initially register all existing metrics * This is called when the reporter is first registered to initially register all existing metrics
* @param metrics All currently existing metrics * @param metrics All currently existing metrics
*/ */
public void init(List<KafkaMetric> metrics); void init(List<KafkaMetric> metrics);
/** /**
* This is called whenever a metric is updated or added * This is called whenever a metric is updated or added
* @param metric * @param metric
*/ */
public void metricChange(KafkaMetric metric); void metricChange(KafkaMetric metric);
/** /**
* This is called whenever a metric is removed * This is called whenever a metric is removed
* @param metric * @param metric
*/ */
public void metricRemoval(KafkaMetric metric); void metricRemoval(KafkaMetric metric);
/** /**
* Called when the metrics repository is closed. * Called when the metrics repository is closed.
*/ */
public void close(); void close();
} }

2
clients/src/main/java/org/apache/kafka/common/metrics/Stat.java
View File

@ -27,6 +27,6 @@ public interface Stat {
* @param value The value to record * @param value The value to record
* @param timeMs The POSIX time in milliseconds this value occurred * @param timeMs The POSIX time in milliseconds this value occurred
*/ */
public void record(MetricConfig config, double value, long timeMs); void record(MetricConfig config, double value, long timeMs);
} }