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
|
#!/usr/bin/env tarantool
os = require('os')
local msgpack = require('msgpack')
box.cfg{
listen = os.getenv("LISTEN"),
memtx_memory = 107374182,
pid_file = "tarantool.pid",
}
require('console').listen(os.getenv('ADMIN'))
local _hide = {
pid_file=1, log=1, listen=1, vinyl_dir=1,
memtx_dir=1, wal_dir=1,
memtx_max_tuple_size=1, memtx_min_tuple_size=1
}
function cfg_filter(data)
if type(data)~='table' then return data end
local keys,k,_ = {}
for k in pairs(data) do
table.insert(keys, k)
end
table.sort(keys)
local result = {}
for _,k in pairs(keys) do
table.insert(result, {k, _hide[k] and '<hidden>' or cfg_filter(data[k])})
end
return result
end
local function compare(a,b)
return a[1] < b[1]
end
function sorted(data)
table.sort(data, compare)
return data
end
function iproto_request(socket, query_header, query_body)
local header = msgpack.encode(query_header)
local body = msgpack.encode(query_body)
local size = msgpack.encode(header:len() + body:len())
assert(socket:write(size .. header .. body) ~= nil,
'Failed to send request')
size = socket:read(5)
assert(size ~= nil, 'Failed to read response')
size = msgpack.decode(size)
local response = socket:read(size)
local header, header_len = msgpack.decode(response)
body = msgpack.decode(response:sub(header_len))
return {
['header'] = header,
['body'] = body,
}
end
_G.protected_globals = {'cfg_filter', 'sorted', 'iproto_request'}
|