Mercurial > prosody-modules

comparison mod_statistics_statsman/mod_statistics_statsman.lua @ 6444:47d88f6e8400

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
mod_statistics_statsman: Replace util.serialization.serialize with %q
author Link Mauve <linkmauve@linkmauve.fr>
date Wed, 11 Mar 2026 00:42:49 +0100
parents bac3dae031ee
children
comparison
equal deleted inserted replaced
6443:7547c2869e78 6444:47d88f6e8400
1 module:set_global(); 1 module:set_global();
2 2
3 local statsman = require "core.statsmanager"; 3 local statsman = require "core.statsmanager";
4 local time_now = require "util.time".now; 4 local time_now = require "util.time".now;
5 local filters = require "util.filters"; 5 local filters = require "util.filters";
6 local serialize = require "util.serialization".serialize;
7 6
8 assert(statsman.get_stats, "not compatible with trunk based on openmetrics"); 7 assert(statsman.get_stats, "not compatible with trunk based on openmetrics");
9 8
10 local statistics_interval = module:context("*"):get_option_number("statistics_interval", 60); 9 local statistics_interval = module:context("*"):get_option_number("statistics_interval", 60);
11 if module:context("*"):get_option("statistics", "internal") ~= "internal" then 10 if module:context("*"):get_option("statistics", "internal") ~= "internal" then
30 ["/*/mod_c2s/connections:amount"] = "total_c2s"; 29 ["/*/mod_c2s/connections:amount"] = "total_c2s";
31 ["/*/mod_s2s/connections:amount"] = "total_s2s"; 30 ["/*/mod_s2s/connections:amount"] = "total_s2s";
32 }; 31 };
33 32
34 local function push_stat(conn, name, value) 33 local function push_stat(conn, name, value)
35 local value_str = serialize(value);
36 name = name_map[name] or name; 34 name = name_map[name] or name;
37 return conn:write((("STAT %q (%s)\n"):format(name, value_str):gsub("\\\n", "\\n"))); 35 return conn:write((("STAT %q (%q)\n"):format(name, value):gsub("\\\n", "\\n")));
38 end 36 end
39 37
40 local function push_stat_to_all(name, value) 38 local function push_stat_to_all(name, value)
41 for conn in pairs(sessions) do 39 for conn in pairs(sessions) do
42 push_stat(conn, name, value); 40 push_stat(conn, name, value);