aboutsummaryrefslogtreecommitdiffstats
path: root/standardization/moher-api/metrics
diff options
context:
space:
mode:
authorPiotr Jaszczyk <piotr.jaszczyk@nokia.com>2019-06-03 14:20:40 +0200
committerPiotr Jaszczyk <piotr.jaszczyk@nokia.com>2019-06-12 09:41:01 +0000
commit3d6feef167f8e8eb716312599132c41dd89457cb (patch)
tree0a3b8b8f7371a0d655fff0146dd70080098f5102 /standardization/moher-api/metrics
parent6c2951519650779c019431f990b22b71feb220dc (diff)
Monitoring API - write framework adapters
Change-Id: Iaba9c4ef6022d01c1f572055316700a3a4dfa8f2 Issue-ID: DCAEGEN2-1589 Signed-off-by: Piotr Jaszczyk <piotr.jaszczyk@nokia.com>
Diffstat (limited to 'standardization/moher-api/metrics')
-rw-r--r--standardization/moher-api/metrics/src/main/java/org/onap/dcaegen2/services/sdk/standardization/moher/metrics/impl/MetricsImpl.java4
1 files changed, 2 insertions, 2 deletions
diff --git a/standardization/moher-api/metrics/src/main/java/org/onap/dcaegen2/services/sdk/standardization/moher/metrics/impl/MetricsImpl.java b/standardization/moher-api/metrics/src/main/java/org/onap/dcaegen2/services/sdk/standardization/moher/metrics/impl/MetricsImpl.java
index e592d976..8ccce84d 100644
--- a/standardization/moher-api/metrics/src/main/java/org/onap/dcaegen2/services/sdk/standardization/moher/metrics/impl/MetricsImpl.java
+++ b/standardization/moher-api/metrics/src/main/java/org/onap/dcaegen2/services/sdk/standardization/moher/metrics/impl/MetricsImpl.java
@@ -42,13 +42,13 @@ public class MetricsImpl implements Metrics {
@Override
public Mono<String> collect() {
- return Mono.just(registry.scrape());
+ return Mono.fromCallable(registry::scrape);
}
@Override
public Flux<String> collect(Duration interval) {
return Flux.interval(interval)
- .map((l) -> registry.scrape());
+ .map(l -> registry.scrape());
}
@SuppressWarnings("squid:S2095")