openwrt-mirror/packages
1
0
Fork 0
mirror of https://github.com/openwrt/packages.git synced 2025-12-22 14:44:36 +04:00
Code Issues Packages Projects Releases Wiki Activity

prometheus-node-exporter-lua: use buffered io, remove concat

Browse Source 
netclass collector scrape time goes from 230ms to 170ms

Signed-off-by: Etienne Champetier <champetier.etienne@gmail.com>
This commit is contained in:
Etienne Champetier
2025-06-29 12:21:54 -04:00
parent f18594a00f
commit 00d420e801
2 changed files with 21 additions and 16 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
utils/prometheus-node-exporter-lua/Makefile
View File

@@ -4,7 +4,7 @@
include $(TOPDIR)/rules.mk include $(TOPDIR)/rules.mk
PKG_NAME:=prometheus-node-exporter-lua PKG_NAME:=prometheus-node-exporter-lua
PKG_VERSION:=2025.06.24 PKG_VERSION:=2025.06.29
PKG_RELEASE:=1 PKG_RELEASE:=1
PKG_MAINTAINER:=Etienne CHAMPETIER <champetier.etienne@gmail.com> PKG_MAINTAINER:=Etienne CHAMPETIER <champetier.etienne@gmail.com>

35
utils/prometheus-node-exporter-lua/files/usr/bin/prometheus-node-exporter-lua
View File

@@ -32,21 +32,24 @@ end
-- Metric printing -- Metric printing
function print_metric(metric, labels, value) function print_metric(metric, labels, value)
local label_string = ""
if type(value) == "nil" then if type(value) == "nil" then
return return
end end
out:write(metric)
if labels then if labels then
out:write("{")
coma = ""
for label,value in pairs(labels) do for label,value in pairs(labels) do
label_string = label_string .. label .. '="' .. value .. '",' out:write(coma, label, '="', value, '"')
coma = ","
end end
label_string = "{" .. string.sub(label_string, 1, -2) .. "}" out:write("}")
end end
output(string.format("%s%s %s", metric, label_string, value)) out:write(" ", value, "\n")
end end
function metric(name, mtype, labels, value) function metric(name, mtype, labels, value)
output("# TYPE " .. name .. " " .. mtype) out:write("# TYPE ", name, " ", mtype, "\n")
local outputter = function(labels, value) local outputter = function(labels, value)
print_metric(name, labels, value) print_metric(name, labels, value)
end end
@@ -83,15 +86,18 @@ end
-- Web server-specific functions -- Web server-specific functions
function handle_request(env) function handle_request(env)
-- use buffered output instead uhttpd.send()
out = io.open("/proc/self/fd/1", "a+")
out:setvbuf("full")
if env.PATH_INFO ~= '/metrics' then if env.PATH_INFO ~= '/metrics' then
uhttpd.send("Status: 404 Not Found\r\n") out:write("Status: 404 Not Found\r\n")
uhttpd.send("Server: lua-metrics\r\n") out:write("Server: lua-metrics\r\n")
uhttpd.send("Content-Type: text/plain\r\n\r\n") out:write("Content-Type: text/plain\r\n\r\n")
uhttpd.send("ERROR: File Not Found.") out:write("ERROR: File Not Found.")
else else
uhttpd.send("Status: 200 OK\r\n") out:write("Status: 200 OK\r\n")
uhttpd.send("Server: lua-metrics\r\n") out:write("Server: lua-metrics\r\n")
uhttpd.send("Content-Type: text/plain; version=0.0.4\r\n\r\n") out:write("Content-Type: text/plain; version=0.0.4\r\n\r\n")
local cols = {} local cols = {}
for c in env.QUERY_STRING:gmatch("collect[^=]*=([^&]+)") do for c in env.QUERY_STRING:gmatch("collect[^=]*=([^&]+)") do
cols[#cols+1] = c cols[#cols+1] = c
@@ -101,6 +107,7 @@ function handle_request(env)
end end
run_all_collectors(cols) run_all_collectors(cols)
end end
out:flush()
end end
-- Main program -- Main program
@@ -115,9 +122,7 @@ for c in ls_fd:lines() do
end end
ls_fd:close() ls_fd:close()
output = function (str) uhttpd.send(str.."\n") end
if arg ~= nil then if arg ~= nil then
output = print out = io.output()
run_all_collectors(col_names) run_all_collectors(col_names)
end end