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
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
|
verbose = true
function say(...)
if verbose then
print(...)
end
end
function mcp_config_pools()
local srv = mcp.backend
local b1 = srv('b1', '127.0.0.1', 12021)
return mcp.pool({b1})
end
function factory(rctx, h)
return function(r)
return rctx:enqueue_and_wait(r, h)
end
end
function d_factory(rctx)
return function(r)
return "SERVER_ERROR default route\r\n"
end
end
function string_fgen(msg)
local fg = mcp.funcgen_new()
fg:ready({ f = function(rctx)
return function(r)
return msg
end
end})
return fg
end
-- TODO: make default path and some other paths that return static data
function mcp_config_routes(p)
local fg = mcp.funcgen_new()
local fgh = fg:new_handle(p)
fg:ready({ f = factory, a = fgh })
local def_fg = mcp.funcgen_new()
def_fg:ready({ f = d_factory })
local map = {
["one"] = fg,
["two"] = fg,
["cmd"] = { [mcp.CMD_GET] = string_fgen("SERVER_ERROR cmd_get\r\n"),
[mcp.CMD_SET] = string_fgen("SERVER_ERROR cmd_set\r\n") },
["cmdd"] = { [mcp.CMD_ANY_STORAGE] = string_fgen("SERVER_ERROR cmd_default\r\n"), },
}
local cmap = {
[mcp.CMD_INCR] = string_fgen("SERVER_ERROR cmap incr\r\n"),
[mcp.CMD_DECR] = string_fgen("SERVER_ERROR cmap decr\r\n")
}
local rpfx_short = mcp.router_new({ map = map, cmap = cmap, mode = "prefix", stop = "|", default = def_fg })
local rpfx_long = mcp.router_new({ map = map, mode = "prefix", stop = "+#+", default = def_fg })
local ranc_short = mcp.router_new({ map = map, mode = "anchor", start = "_", stop = ",", default = def_fg })
local ranc_long = mcp.router_new({ map = map, mode = "anchor", start = "=?=", stop = "__", default = def_fg })
local cmap_only = mcp.router_new({
cmap = {
[mcp.CMD_GETS] = string_fgen("SERVER_ERROR cmap_only gets\r\n")
},
default = string_fgen("SERVER_ERROR cmap_only default\r\n"),
})
mcp.attach(mcp.CMD_ANY_STORAGE, rpfx_short)
mcp.attach(mcp.CMD_MG, rpfx_short)
mcp.attach(mcp.CMD_MS, rpfx_long)
mcp.attach(mcp.CMD_MD, ranc_short)
mcp.attach(mcp.CMD_MA, ranc_long)
mcp.attach(mcp.CMD_GETS, cmap_only)
mcp.attach(mcp.CMD_GAT, cmap_only)
end
|
