|
3732
|
1 local pack = require "util.table".pack; |
|
|
2 local json = require "util.json"; |
|
|
3 local array = require "util.array"; |
|
|
4 local datetime = require "util.datetime".datetime; |
|
3746
|
5 local socket = require "socket"; |
|
3732
|
6 |
|
|
7 module:set_global(); |
|
|
8 |
|
|
9 local function sink_maker(config) |
|
3746
|
10 local send = function () end |
|
|
11 if config.filename then |
|
|
12 local logfile = io.open(config.filename, "a+"); |
|
|
13 logfile:setvbuf("no"); |
|
|
14 function send(payload) |
|
|
15 logfile:write(payload, "\n"); |
|
|
16 end |
|
|
17 elseif config.udp_host and config.udp_port then |
|
|
18 local conn = socket.udp(); |
|
|
19 conn:connect(config.udphost, config.udpport); |
|
|
20 function send(payload) |
|
|
21 conn:send(payload); |
|
|
22 end |
|
|
23 end |
|
3732
|
24 return function (source, level, message, ...) |
|
|
25 local args = pack(...); |
|
|
26 for i = 1, args.n do |
|
|
27 if args[i] == nil then |
|
|
28 args[i] = json.null; |
|
|
29 elseif type(args[i]) ~= "string" or type(args[i]) ~= "number" then |
|
|
30 args[i] = tostring(args[i]); |
|
|
31 end |
|
|
32 end |
|
|
33 args.n = nil; |
|
|
34 local payload = { |
|
|
35 datetime = datetime(), |
|
|
36 source = source, |
|
|
37 level = level, |
|
|
38 message = message, |
|
|
39 args = array(args); |
|
|
40 }; |
|
3746
|
41 send(json.encode(payload)); |
|
3732
|
42 end |
|
|
43 end |
|
|
44 |
|
|
45 require"core.loggingmanager".register_sink_type("json", sink_maker); |
