summaryrefslogtreecommitdiff
path: root/src
diff options
context:
space:
mode:
Diffstat (limited to 'src')
-rw-r--r--src/daq/nginx-lua/s5-nginx.lua36
1 files changed, 29 insertions, 7 deletions
diff --git a/src/daq/nginx-lua/s5-nginx.lua b/src/daq/nginx-lua/s5-nginx.lua
index 8393562..3d6ad8e 100644
--- a/src/daq/nginx-lua/s5-nginx.lua
+++ b/src/daq/nginx-lua/s5-nginx.lua
@@ -39,7 +39,18 @@
-- lua_shared_dict sfive_locks 64k;
-- lua_shared_dict sfive_data 64m;
-- init_by_lua 's5 = require "s5-nginx.lua"';
--- init_worker_by_lua 's5.init_worker("myhostname", 5, "/path/to/sfive.sock")';
+-- init_worker_by_lua '
+-- s5.init_worker("myhostname", 5, "/path/to/sfive.sock",
+-- { "tag1", "tag2" },
+-- { { "contentA", "format1", "low" },
+-- { "contentA", "format1", "high" },
+-- { "contentB", "format1", "low" },
+-- { "contentB", "format1", "high" },
+-- { "contentA", "format2", "low" },
+-- { "contentA", "format2", "high" },
+-- { "contentB", "format2", "low" },
+-- { "contentB", "format2", "high" } })
+-- ';
--
-- .....
--
@@ -47,10 +58,12 @@
--
-- .....
--
--- location /path/to/hls/content-quality/ {
--- log_by_lua 's5.log("content", "hls", "quality")';
+-- location /path/to/fromat1/contentA-low/ {
+-- log_by_lua 's5.log("contentA", "format1", "low")';
+-- }
+-- location /path/to/fromat1/contentA-high/ {
+-- log_by_lua 's5.log("contentA", "format1", "high")';
-- }
---
-- .....
--
-- }
@@ -66,6 +79,8 @@ local config = {
hostname = "unknown",
duration = 5,
sockpath = "/var/run/sfive.sock",
+ tags = {},
+ streamer = {}
}
local sfive = ngx.shared.sfive
local sfive_data = ngx.shared.sfive_data
@@ -122,8 +137,13 @@ end
local send_init = function(sock)
local json = '{'
- json = json .. '"version": 1,'
- json = json .. '"hostname": "' .. config.hostname .. '"'
+ json = json .. '"version": 1'
+ json = json .. ',"hostname": "' .. config.hostname .. '"'
+ json = json .. ',"tags": ['
+ for i, k in ipairs(config.tags) do
+ json = json .. (i==1 and '' or ',') .. '"' .. k .. '"'
+ end
+ json = json .. ']'
json = json .. '}\n'
return sock:send(json)
end
@@ -194,10 +214,12 @@ local init = function()
ngx.log(ngx.INFO, "SFive(init): task initialized successfully!")
end
-function _SFIVE.init_worker(hostname, duration, sockpath)
+function _SFIVE.init_worker(hostname, duration, sockpath, tags, streamer)
config.hostname = hostname
config.duration = duration
config.sockpath = sockpath
+ config.tags = (tags and tags or {})
+ config.streamer = (streamer and streamer or {})
init()
ngx.log(ngx.INFO, "SFive(init): worker initialized successfully!")
end