|
1 | | -queue = require('queue') |
| 1 | +local queue = require('queue') |
| 2 | +rawset(_G, 'queue', queue) |
2 | 3 |
|
3 | 4 | -- Do not set listen for now so connector won't be |
4 | 5 | -- able to send requests until everything is configured. |
5 | 6 | box.cfg{ |
6 | 7 | work_dir = os.getenv("TEST_TNT_WORK_DIR"), |
7 | 8 | } |
8 | 9 |
|
9 | | -box.once("init", function() |
10 | | -box.schema.user.create('test', {password = 'test'}) |
11 | | -box.schema.func.create('queue.tube.test_queue:ack') |
12 | | -box.schema.func.create('queue.tube.test_queue:put') |
13 | | -box.schema.func.create('queue.tube.test_queue:drop') |
14 | | -box.schema.func.create('queue.tube.test_queue:peek') |
15 | | -box.schema.func.create('queue.tube.test_queue:kick') |
16 | | -box.schema.func.create('queue.tube.test_queue:take') |
17 | | -box.schema.func.create('queue.tube.test_queue:delete') |
18 | | -box.schema.func.create('queue.tube.test_queue:release') |
19 | | -box.schema.func.create('queue.tube.test_queue:bury') |
20 | | -box.schema.func.create('queue.statistics') |
21 | | -box.schema.user.grant('test', 'create', 'space') |
22 | | -box.schema.user.grant('test', 'write', 'space', '_schema') |
23 | | -box.schema.user.grant('test', 'write', 'space', '_space') |
24 | | -box.schema.user.grant('test', 'read,write', 'space', '_space_sequence') |
25 | | -box.schema.user.grant('test', 'write', 'space', '_index') |
26 | | -box.schema.user.grant('test', 'read, write', 'space', '_queue_session_ids') |
27 | | -box.schema.user.grant('test', 'execute', 'universe') |
28 | | -box.schema.user.grant('test', 'read,write', 'space', '_queue') |
29 | | -box.schema.user.grant('test', 'read,write', 'space', '_schema') |
30 | | -box.schema.user.grant('test', 'read,write', 'space', '_space') |
31 | | -box.schema.user.grant('test', 'read,write', 'space', '_index') |
32 | | -box.schema.user.grant('test', 'read,write', 'space', '_queue_consumers') |
33 | | -box.schema.user.grant('test', 'read,write', 'space', '_priv') |
34 | | -box.schema.user.grant('test', 'read,write', 'space', '_queue_taken_2') |
35 | | -if box.space._trigger ~= nil then |
36 | | - box.schema.user.grant('test', 'read', 'space', '_trigger') |
37 | | -end |
38 | | -if box.space._fk_constraint ~= nil then |
39 | | - box.schema.user.grant('test', 'read', 'space', '_fk_constraint') |
40 | | -end |
41 | | -if box.space._ck_constraint ~= nil then |
42 | | - box.schema.user.grant('test', 'read', 'space', '_ck_constraint') |
43 | | -end |
44 | | -if box.space._func_index ~= nil then |
45 | | - box.schema.user.grant('test', 'read', 'space', '_func_index') |
46 | | -end |
| 10 | + box.once("init", function() |
| 11 | + box.schema.user.create('test', {password = 'test'}) |
| 12 | + box.schema.func.create('queue.tube.test_queue:ack') |
| 13 | + box.schema.func.create('queue.tube.test_queue:put') |
| 14 | + box.schema.func.create('queue.tube.test_queue:drop') |
| 15 | + box.schema.func.create('queue.tube.test_queue:peek') |
| 16 | + box.schema.func.create('queue.tube.test_queue:kick') |
| 17 | + box.schema.func.create('queue.tube.test_queue:take') |
| 18 | + box.schema.func.create('queue.tube.test_queue:delete') |
| 19 | + box.schema.func.create('queue.tube.test_queue:release') |
| 20 | + box.schema.func.create('queue.tube.test_queue:bury') |
| 21 | + box.schema.func.create('queue.statistics') |
| 22 | + box.schema.user.grant('test', 'create', 'space') |
| 23 | + box.schema.user.grant('test', 'write', 'space', '_schema') |
| 24 | + box.schema.user.grant('test', 'write', 'space', '_space') |
| 25 | + box.schema.user.grant('test', 'read,write', 'space', '_space_sequence') |
| 26 | + box.schema.user.grant('test', 'write', 'space', '_index') |
| 27 | + box.schema.user.grant('test', 'read, write', 'space', '_queue_session_ids') |
| 28 | + box.schema.user.grant('test', 'execute', 'universe') |
| 29 | + box.schema.user.grant('test', 'read,write', 'space', '_queue') |
| 30 | + box.schema.user.grant('test', 'read,write', 'space', '_schema') |
| 31 | + box.schema.user.grant('test', 'read,write', 'space', '_space') |
| 32 | + box.schema.user.grant('test', 'read,write', 'space', '_index') |
| 33 | + box.schema.user.grant('test', 'read,write', 'space', '_queue_consumers') |
| 34 | + box.schema.user.grant('test', 'read,write', 'space', '_priv') |
| 35 | + box.schema.user.grant('test', 'read,write', 'space', '_queue_taken_2') |
| 36 | + if box.space._trigger ~= nil then |
| 37 | + box.schema.user.grant('test', 'read', 'space', '_trigger') |
| 38 | + end |
| 39 | + if box.space._fk_constraint ~= nil then |
| 40 | + box.schema.user.grant('test', 'read', 'space', '_fk_constraint') |
| 41 | + end |
| 42 | + if box.space._ck_constraint ~= nil then |
| 43 | + box.schema.user.grant('test', 'read', 'space', '_ck_constraint') |
| 44 | + end |
| 45 | + if box.space._func_index ~= nil then |
| 46 | + box.schema.user.grant('test', 'read', 'space', '_func_index') |
| 47 | + end |
47 | 48 | end) |
48 | 49 |
|
49 | 50 | -- Set listen only when every other thing is configured. |
|
0 commit comments