This repository has been archived by the owner on May 24, 2023. It is now read-only.
forked from mesosphere/marathon-lb
-
Notifications
You must be signed in to change notification settings - Fork 18
/
getmaps.lua
59 lines (52 loc) · 1.6 KB
/
getmaps.lua
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
-- A simple Lua script which serves up the HAProxy
-- vhost to backend map file.
function check_file_exists(name)
local f = io.open(name, "r")
if f ~= nil then io.close(f) return true else return false end
end
function read_file(filepath)
-- Read all of the given file, returning an empty string if the file doesn't
-- exist.
local content = ""
if check_file_exists(filepath) then
local f = io.open(filepath, "rb")
content = f:read("*all")
f:close()
end
return content
end
function detect_config_dir()
-- Read the process's (HAProxy's) cmdline proc and parse the path to the
-- config file so that we can determine the config directory.
local f = io.open("/proc/self/cmdline", "rb")
local cmdline = f:read("*all")
f:close()
local found = false
local sep = package.config:sub(1, 1)
for opt in string.gmatch(cmdline, "%g+") do
if opt == "-f" then
found = true
elseif found then
return opt:match("(.*"..sep..")")
end
end
end
function load_map(filename)
local config_dir = detect_config_dir()
return read_file(config_dir..filename)
end
function send_map(applet, map)
applet:set_status(200)
applet:add_header("content-length", string.len(map))
applet:add_header("content-type", "text/plain")
applet:start_response()
applet:send(map)
end
core.register_service("getvhostmap", "http", function(applet)
local haproxy_vhostmap = load_map("domain2backend.map")
send_map(applet, haproxy_vhostmap)
end)
core.register_service("getappmap", "http", function(applet)
local haproxy_appmap = load_map("app2backend.map")
send_map(applet, haproxy_appmap)
end)