diff options
| author | Henry Spanka <henry@spanka.eu> | 2024-10-18 10:08:56 +0200 |
|---|---|---|
| committer | Vsevolod Stakhov <vsevolod@rspamd.com> | 2024-10-20 10:05:18 +0100 |
| commit | d1381906de4fd69498dd55ae1f58bdec15de9099 (patch) | |
| tree | b0b3796429a35f76e8d8f4b7ba3bef6f4f1ece92 | |
| parent | 35537b44221171b44c2ef1b37072305df5bd113b (diff) | |
| download | rspamd-d1381906de4fd69498dd55ae1f58bdec15de9099.tar.gz rspamd-d1381906de4fd69498dd55ae1f58bdec15de9099.zip | |
add EOF to openmetrics response in proxy and server
| -rw-r--r-- | src/libserver/protocol.c | 1 | ||||
| -rw-r--r-- | src/rspamd_proxy.c | 1 |
2 files changed, 2 insertions, 0 deletions
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; |