This is an automated email from the ASF dual-hosted git repository.
ymdavis pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/nifi.git.
from 1473652 NIFI-6801 - fix to ensure unique model instance is created
for each connection. Also increased default query interval.
add 8771c35 NIFI-6799: Add PrometheusRecordSink and reset() method to
RecordSinkService (#3839)
No new revisions were added by this update.
Summary of changes:
.../nifi-prometheus-reporting-task/pom.xml | 15 ++
.../reporting/prometheus/PrometheusRecordSink.java | 208 +++++++++++++++++++++
.../prometheus/PrometheusReportingTask.java | 97 +++-------
.../reporting/prometheus/PrometheusServer.java | 48 ++---
.../prometheus/api/PrometheusMetricsUtil.java | 52 ++++++
.../org.apache.nifi.controller.ControllerService | 2 +-
.../prometheus/TestPrometheusRecordSink.java | 140 ++++++++++++++
.../prometheus/TestPrometheusReportingTask.java | 8 +-
.../nifi/reporting/sql/QueryNiFiReportingTask.java | 13 +-
.../reporting/sql/TestQueryNiFiReportingTask.java | 6 +-
.../apache/nifi/record/sink/RecordSinkService.java | 18 ++
11 files changed, 498 insertions(+), 109 deletions(-)
create mode 100644
nifi-nar-bundles/nifi-prometheus-bundle/nifi-prometheus-reporting-task/src/main/java/org/apache/nifi/reporting/prometheus/PrometheusRecordSink.java
copy nifi-nar-bundles/{nifi-easyrules-bundle/nifi-easyrules-service =>
nifi-prometheus-bundle/nifi-prometheus-reporting-task}/src/main/resources/META-INF/services/org.apache.nifi.controller.ControllerService
(93%)
create mode 100644
nifi-nar-bundles/nifi-prometheus-bundle/nifi-prometheus-reporting-task/src/test/java/org/apache/nifi/reporting/prometheus/TestPrometheusRecordSink.java