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
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
|
fiber = require 'fiber'
---
...
net = require('net.box')
---
...
--
-- gh-2677: netbox supports console connections, that complicates
-- both console and netbox. It was necessary because before a
-- connection is established, a console does not known is it
-- binary or text protocol, and netbox could not be created from
-- existing socket.
--
box.schema.user.grant('guest', 'execute', 'universe')
---
...
urilib = require('uri')
---
...
uri = urilib.parse(tostring(box.cfg.listen))
---
...
s, greeting = net.establish_connection(uri.host, uri.service)
---
...
c = net.wrap(s, greeting, uri.host, uri.service, {reconnect_after = 0.01})
---
...
c.state
---
- active
...
a = 100
---
...
function kek(args) return {1, 2, 3, args} end
---
...
c:eval('a = 200')
---
...
a
---
- 200
...
c:call('kek', {300})
---
- [1, 2, 3, 300]
...
s = box.schema.create_space('test')
---
...
box.schema.user.grant('guest', 'read,write', 'space', 'test')
---
...
pk = s:create_index('pk')
---
...
c:reload_schema()
---
...
c.space.test:replace{1}
---
- [1]
...
c.space.test:get{1}
---
- [1]
...
c.space.test:delete{1}
---
- [1]
...
--
-- Break a connection to test reconnect_after.
--
_ = c._transport.perform_request(nil, nil, false, 'inject', nil, nil, nil, '\x80')
---
...
while not c:is_connected() do fiber.sleep(0.01) end
---
...
c:ping()
---
- true
...
s:drop()
---
...
c:close()
---
...
box.schema.user.revoke('guest', 'execute', 'universe')
---
...
|
