Browse Source
Merge pull request #5192 from henry-spanka/add-eof-to-openmetrics
add EOF to openmetrics response in proxy and server
pull/5193/head
Vsevolod Stakhov
1 year ago
committed by
GitHub
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
2 changed files with
2 additions and
0 deletions
-
src/libserver/protocol.c
-
src/rspamd_proxy.c
|
|
|
@ -2092,6 +2092,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; |
|
|
|
|
|
|
|
@ -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; |
|
|
|
|