Skip to content

Commit db0fc2b

Browse files
committed
nullaway
Signed-off-by: Gregor Zeitlinger <[email protected]>
1 parent 80817b6 commit db0fc2b

File tree

8 files changed

+18
-12
lines changed

8 files changed

+18
-12
lines changed

prometheus-metrics-exporter-common/src/main/java/io/prometheus/metrics/exporter/common/PrometheusScrapeHandler.java

Lines changed: 5 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -18,13 +18,14 @@
1818
import java.util.concurrent.atomic.AtomicInteger;
1919
import java.util.function.Predicate;
2020
import java.util.zip.GZIPOutputStream;
21+
import javax.annotation.Nullable;
2122

2223
/** Prometheus scrape endpoint. */
2324
public class PrometheusScrapeHandler {
2425

2526
private final PrometheusRegistry registry;
2627
private final ExpositionFormats expositionFormats;
27-
private final Predicate<String> nameFilter;
28+
@Nullable private final Predicate<String> nameFilter;
2829
private final AtomicInteger lastResponseSize = new AtomicInteger(2 << 9); // 0.5 MB
2930
private final List<String> supportedFormats;
3031

@@ -97,6 +98,7 @@ public void handleRequest(PrometheusHttpExchange exchange) throws IOException {
9798
}
9899
}
99100

101+
@Nullable
100102
private Predicate<String> makeNameFilter(ExporterFilterProperties props) {
101103
if (props.getAllowedMetricNames() == null
102104
&& props.getExcludedMetricNames() == null
@@ -113,7 +115,8 @@ private Predicate<String> makeNameFilter(ExporterFilterProperties props) {
113115
}
114116
}
115117

116-
private Predicate<String> makeNameFilter(String[] includedNames) {
118+
@Nullable
119+
private Predicate<String> makeNameFilter(@Nullable String[] includedNames) {
117120
Predicate<String> result = null;
118121
if (includedNames != null && includedNames.length > 0) {
119122
result = MetricNameFilter.builder().nameMustBeEqualTo(includedNames).build();

prometheus-metrics-exposition-formats/src/main/java/io/prometheus/metrics/expositionformats/internal/PrometheusProtobufWriterImpl.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -29,7 +29,7 @@
2929
public class PrometheusProtobufWriterImpl implements ExpositionFormatWriter {
3030

3131
@Override
32-
public boolean accepts(String acceptHeader) {
32+
public boolean accepts(@Nullable String acceptHeader) {
3333
throw new IllegalStateException("use PrometheusProtobufWriter instead");
3434
}
3535

prometheus-metrics-exposition-textformats/src/main/java/io/prometheus/metrics/expositionformats/ExpositionFormatWriter.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -4,9 +4,10 @@
44
import java.io.ByteArrayOutputStream;
55
import java.io.IOException;
66
import java.io.OutputStream;
7+
import javax.annotation.Nullable;
78

89
public interface ExpositionFormatWriter {
9-
boolean accepts(String acceptHeader);
10+
boolean accepts(@Nullable String acceptHeader);
1011

1112
/** Text formats use UTF-8 encoding. */
1213
void write(OutputStream out, MetricSnapshots metricSnapshots) throws IOException;

prometheus-metrics-exposition-textformats/src/main/java/io/prometheus/metrics/expositionformats/ExpositionFormats.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -2,6 +2,7 @@
22

33
import io.prometheus.metrics.config.ExporterProperties;
44
import io.prometheus.metrics.config.PrometheusProperties;
5+
import javax.annotation.Nullable;
56

67
public class ExpositionFormats {
78

@@ -36,7 +37,7 @@ public static ExpositionFormats init(ExporterProperties properties) {
3637
.build());
3738
}
3839

39-
public ExpositionFormatWriter findWriter(String acceptHeader) {
40+
public ExpositionFormatWriter findWriter(@Nullable String acceptHeader) {
4041
if (prometheusProtobufWriter.accepts(acceptHeader)) {
4142
return prometheusProtobufWriter;
4243
}

prometheus-metrics-exposition-textformats/src/main/java/io/prometheus/metrics/expositionformats/OpenMetricsTextFormatWriter.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -91,7 +91,7 @@ public static OpenMetricsTextFormatWriter create() {
9191
}
9292

9393
@Override
94-
public boolean accepts(String acceptHeader) {
94+
public boolean accepts(@Nullable String acceptHeader) {
9595
if (acceptHeader == null) {
9696
return false;
9797
}

prometheus-metrics-exposition-textformats/src/main/java/io/prometheus/metrics/expositionformats/PrometheusProtobufWriter.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -34,7 +34,7 @@ private static ExpositionFormatWriter createProtobufWriter() {
3434
}
3535

3636
@Override
37-
public boolean accepts(String acceptHeader) {
37+
public boolean accepts(@Nullable String acceptHeader) {
3838
if (acceptHeader == null) {
3939
return false;
4040
} else {

prometheus-metrics-exposition-textformats/src/main/java/io/prometheus/metrics/expositionformats/PrometheusTextFormatWriter.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -89,7 +89,7 @@ public static PrometheusTextFormatWriter create() {
8989
}
9090

9191
@Override
92-
public boolean accepts(String acceptHeader) {
92+
public boolean accepts(@Nullable String acceptHeader) {
9393
if (acceptHeader == null) {
9494
return false;
9595
} else {

prometheus-metrics-model/src/main/java/io/prometheus/metrics/model/registry/MetricNameFilter.java

Lines changed: 5 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -6,6 +6,7 @@
66
import java.util.Arrays;
77
import java.util.Collection;
88
import java.util.function.Predicate;
9+
import javax.annotation.Nullable;
910

1011
/** Filter samples (i.e. time series) by name. */
1112
public class MetricNameFilter implements Predicate<String> {
@@ -121,7 +122,7 @@ public Builder nameMustBeEqualTo(String... names) {
121122
*
122123
* @param names empty means no restriction.
123124
*/
124-
public Builder nameMustBeEqualTo(Collection<String> names) {
125+
public Builder nameMustBeEqualTo(@Nullable Collection<String> names) {
125126
if (names != null) {
126127
nameEqualTo.addAll(names);
127128
}
@@ -144,7 +145,7 @@ public Builder nameMustNotBeEqualTo(String... names) {
144145
*
145146
* @param names empty means no name will be excluded.
146147
*/
147-
public Builder nameMustNotBeEqualTo(Collection<String> names) {
148+
public Builder nameMustNotBeEqualTo(@Nullable Collection<String> names) {
148149
if (names != null) {
149150
nameNotEqualTo.addAll(names);
150151
}
@@ -163,7 +164,7 @@ public Builder nameMustStartWith(String... prefixes) {
163164
*
164165
* @param prefixes empty means no restriction.
165166
*/
166-
public Builder nameMustStartWith(Collection<String> prefixes) {
167+
public Builder nameMustStartWith(@Nullable Collection<String> prefixes) {
167168
if (prefixes != null) {
168169
nameStartsWith.addAll(prefixes);
169170
}
@@ -182,7 +183,7 @@ public Builder nameMustNotStartWith(String... prefixes) {
182183
*
183184
* @param prefixes empty means no time series will be excluded.
184185
*/
185-
public Builder nameMustNotStartWith(Collection<String> prefixes) {
186+
public Builder nameMustNotStartWith(@Nullable Collection<String> prefixes) {
186187
if (prefixes != null) {
187188
nameDoesNotStartWith.addAll(prefixes);
188189
}

0 commit comments

Comments
 (0)