You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@karaf.apache.org by jb...@apache.org on 2021/09/12 16:56:24 UTC
[karaf-decanter] branch main updated: [KARAF-7154] Improve
prometheus appender
This is an automated email from the ASF dual-hosted git repository.
jbonofre pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/karaf-decanter.git
The following commit(s) were added to refs/heads/main by this push:
new 181f4c5 [KARAF-7154] Improve prometheus appender
new a671e57 Merge pull request #269 from jbonofre/KARAF-7154
181f4c5 is described below
commit 181f4c5ee56464e1dd7598d6fedc81dbf49b3d92
Author: Jean-Baptiste Onofré <jb...@apache.org>
AuthorDate: Thu Sep 9 11:09:16 2021 +0200
[KARAF-7154] Improve prometheus appender
---
.../appender/prometheus/PrometheusServlet.java | 64 +++++++++++++++++-----
1 file changed, 50 insertions(+), 14 deletions(-)
diff --git a/appender/prometheus/src/main/java/org/apache/karaf/decanter/appender/prometheus/PrometheusServlet.java b/appender/prometheus/src/main/java/org/apache/karaf/decanter/appender/prometheus/PrometheusServlet.java
index e85bfaa..e9f1d2e 100644
--- a/appender/prometheus/src/main/java/org/apache/karaf/decanter/appender/prometheus/PrometheusServlet.java
+++ b/appender/prometheus/src/main/java/org/apache/karaf/decanter/appender/prometheus/PrometheusServlet.java
@@ -28,6 +28,8 @@ import org.osgi.service.event.EventConstants;
import org.osgi.service.event.EventHandler;
import org.osgi.service.http.HttpService;
+import java.util.Dictionary;
+import java.util.Enumeration;
import java.util.HashMap;
import java.util.Map;
@@ -41,15 +43,18 @@ public class PrometheusServlet implements EventHandler {
@Reference
HttpService httpService;
- private String alias = "/decanter/prometheus";
+ private Dictionary<String, Object> config;
+
+ private String alias;
+ private boolean filtered = false;
private Map<String, Gauge> gauges = new HashMap<>();
@Activate
public void activate(ComponentContext componentContext) throws Exception {
- if (componentContext.getProperties().get("alias") != null) {
- alias = componentContext.getProperties().get("alias").toString();
- }
+ config = componentContext.getProperties();
+ setFiltered();
+ alias = (config.get("alias") != null) ? (String) config.get("alias") : "/decanter/prometheus";
httpService.registerServlet(alias, new MetricsServlet(), null, null);
}
@@ -61,20 +66,51 @@ public class PrometheusServlet implements EventHandler {
@Override
public void handleEvent(Event event) {
for (String property : event.getPropertyNames()) {
- if (event.getProperty(property) instanceof Long || event.getProperty(property) instanceof Integer) {
- String convertedProperty = property.replace(".", "_");
- Gauge gauge = gauges.get(convertedProperty);
- if (gauge == null) {
- gauge = Gauge.build().name(convertedProperty).help(property).register();
- gauges.put(convertedProperty, gauge);
+ if (!filtered || (filtered && config.get("prometheus.key." + property) != null)) {
+ if (event.getProperty(property) instanceof Map) {
+ Map<String, Object> map = (Map) event.getProperty(property);
+ for (Map.Entry<String, Object> entry : map.entrySet()) {
+ if (entry.getValue() instanceof Long || entry.getValue() instanceof Integer) {
+ String convertedProperty = (property + "." + entry.getKey()).replace(".", "_");
+ Gauge gauge = gauges.get(convertedProperty);
+ if (gauge == null) {
+ gauge = Gauge.build().name(convertedProperty).help(property + "." + entry.getKey()).register();
+ gauges.put(convertedProperty, gauge);
+ }
+ if (entry.getValue() instanceof Long) {
+ gauge.set((Long) entry.getValue());
+ } else if (entry.getValue() instanceof Integer) {
+ gauge.set((Integer) entry.getValue());
+ }
+ }
+ }
}
- if (event.getProperty(property) instanceof Long) {
- gauge.set((Long) event.getProperty(property));
- } else if (event.getProperty(property) instanceof Integer) {
- gauge.set((Integer) event.getProperty(property));
+ if (event.getProperty(property) instanceof Long || event.getProperty(property) instanceof Integer) {
+ String convertedProperty = property.replace(".", "_");
+ Gauge gauge = gauges.get(convertedProperty);
+ if (gauge == null) {
+ gauge = Gauge.build().name(convertedProperty).help(property).register();
+ gauges.put(convertedProperty, gauge);
+ }
+ if (event.getProperty(property) instanceof Long) {
+ gauge.set((Long) event.getProperty(property));
+ } else if (event.getProperty(property) instanceof Integer) {
+ gauge.set((Integer) event.getProperty(property));
+ }
}
}
}
}
+ private void setFiltered() {
+ Enumeration<String> keys = config.keys();
+ while (keys.hasMoreElements()) {
+ String key = keys.nextElement();
+ if (key.startsWith("prometheus.key")) {
+ filtered = true;
+ return;
+ }
+ }
+ }
+
}