From: Henry Spanka <henry@spanka.eu>
Date: Fri, 18 Oct 2024 08:08:56 +0000 (+0200)
Subject: add EOF to openmetrics response in proxy and server
X-Git-Tag: 3.10.2~1
X-Git-Url: https://source.dussan.org/?a=commitdiff_plain;h=d1381906de4fd69498dd55ae1f58bdec15de9099;p=rspamd.git

add EOF to openmetrics response in proxy and server
---

diff --git a/src/libserver/protocol.c b/src/libserver/protocol.c
index a86111ff2..73660114d 100644
--- a/src/libserver/protocol.c
+++ b/src/libserver/protocol.c
@@ -2091,6 +2091,7 @@ void rspamd_protocol_write_reply(struct rspamd_task *task, ev_tstamp timeout, st
 			memcpy(&stat_copy, srv->stat, sizeof(stat_copy));
 			output = rspamd_metrics_to_prometheus_string(
 				rspamd_worker_metrics_object(srv->cfg, &stat_copy, now - srv->start_time));
+			rspamd_printf_fstring(&output, "# EOF\n");
 			rspamd_http_message_set_body_from_fstring_steal(msg, output);
 			ctype = "application/openmetrics-text; version=1.0.0; charset=utf-8";
 			break;
diff --git a/src/rspamd_proxy.c b/src/rspamd_proxy.c
index e2a866178..694e87c12 100644
--- a/src/rspamd_proxy.c
+++ b/src/rspamd_proxy.c
@@ -1768,6 +1768,7 @@ rspamd_proxy_scan_self_reply(struct rspamd_task *task)
 		memcpy(&stat_copy, session->ctx->srv->stat, sizeof(stat_copy));
 		output = rspamd_metrics_to_prometheus_string(
 			rspamd_worker_metrics_object(task->cfg, &stat_copy, ev_time() - session->ctx->srv->start_time));
+		rspamd_printf_fstring(&output, "# EOF\n");
 		rspamd_http_message_set_body_from_fstring_steal(msg, output);
 		ctype = "application/openmetrics-text; version=1.0.0; charset=utf-8";
 		break;