Skip to content

Commit a3716c2

Browse files
igorcodingrtsisyk
igorcoding
authored and
rtsisyk
committed
Fix queue spaces formats
1 parent 3adda75 commit a3716c2

File tree

5 files changed

+38
-38
lines changed

5 files changed

+38
-38
lines changed

‎queue/abstract.lua‎

Lines changed: 14 additions & 14 deletions
Original file line numberDiff line numberDiff line change
@@ -444,11 +444,11 @@ function method.start()
444444
if _queue == nil then
445445
_queue = box.schema.create_space('_queue', {
446446
format = {
447-
[1] = {name = 'tube_name', type = str_type()},
448-
[2] = {name = 'tube_id', type = num_type()},
449-
[3] = {name = 'space_name', type = str_type()},
450-
[4] = {name = 'tube_type', type = str_type()},
451-
[5] = {name = 'opts', type = '*'}
447+
{name = 'tube_name', type = str_type()},
448+
{name = 'tube_id', type = num_type()},
449+
{name = 'space_name', type = str_type()},
450+
{name = 'tube_type', type = str_type()},
451+
{name = 'opts', type = '*'}
452452
}
453453
})
454454
_queue:create_index('tube', {
@@ -469,11 +469,11 @@ function method.start()
469469
_cons = box.schema.create_space('_queue_consumers', {
470470
temporary = true,
471471
format = {
472-
[1] = {name = 'session_id', type = num_type()},
473-
[2] = {name = 'fiber_id', type = num_type()},
474-
[3] = {name = 'tube_id', type = num_type()},
475-
[4] = {name = 'event_time', type = num_type()},
476-
[5] = {name = 'fiber_time', type = num_type()}
472+
{name = 'session_id', type = num_type()},
473+
{name = 'fiber_id', type = num_type()},
474+
{name = 'tube_id', type = num_type()},
475+
{name = 'event_time', type = num_type()},
476+
{name = 'fiber_time', type = num_type()}
477477
}
478478
})
479479
_cons:create_index('pk', {
@@ -494,10 +494,10 @@ function method.start()
494494
_taken = box.schema.create_space('_queue_taken', {
495495
temporary = true,
496496
format = {
497-
[1] = {name = 'session_id', type = num_type()},
498-
[2] = {name = 'tube_id', type = num_type()},
499-
[3] = {name = 'task_id', type = num_type()},
500-
[4] = {name = 'taken_time', type = num_type()}
497+
{name = 'session_id', type = num_type()},
498+
{name = 'tube_id', type = num_type()},
499+
{name = 'task_id', type = num_type()},
500+
{name = 'taken_time', type = num_type()}
501501
}})
502502
_taken:create_index('pk', {
503503
type = 'tree',

‎queue/abstract/driver/fifo.lua‎

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -14,9 +14,9 @@ function tube.create_space(space_name, opts)
1414
space_opts.if_not_exists = if_not_exists
1515
space_opts.engine = opts.engine or 'memtx'
1616
space_opts.format = {
17-
[1] = {name = 'task_id', type = num_type()},
18-
[2] = {name = 'status', type = str_type()},
19-
[3] = {name = 'data', type = '*'}
17+
{name = 'task_id', type = num_type()},
18+
{name = 'status', type = str_type()},
19+
{name = 'data', type = '*'}
2020
}
2121

2222
local space = box.schema.create_space(space_name, space_opts)

‎queue/abstract/driver/fifottl.lua‎

Lines changed: 8 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -55,14 +55,14 @@ function tube.create_space(space_name, opts)
5555
space_opts.if_not_exists = if_not_exists
5656
space_opts.engine = opts.engine or 'memtx'
5757
space_opts.format = {
58-
[1] = {name = 'task_id', type = num_type()},
59-
[2] = {name = 'status', type = str_type()},
60-
[3] = {name = 'next_event', type = num_type()},
61-
[4] = {name = 'ttl', type = num_type()},
62-
[5] = {name = 'ttr', type = num_type()},
63-
[6] = {name = 'pri', type = num_type()},
64-
[7] = {name = 'created', type = num_type()},
65-
[8] = {name = 'data', type = '*'}
58+
{name = 'task_id', type = num_type()},
59+
{name = 'status', type = str_type()},
60+
{name = 'next_event', type = num_type()},
61+
{name = 'ttl', type = num_type()},
62+
{name = 'ttr', type = num_type()},
63+
{name = 'pri', type = num_type()},
64+
{name = 'created', type = num_type()},
65+
{name = 'data', type = '*'}
6666
}
6767

6868
-- 1 2 3 4 5 6 7, 8

‎queue/abstract/driver/utube.lua‎

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -15,10 +15,10 @@ function tube.create_space(space_name, opts)
1515
space_opts.if_not_exists = if_not_exists
1616
space_opts.engine = opts.engine or 'memtx'
1717
space_opts.format = {
18-
[1] = {name = 'task_id', type = num_type()},
19-
[2] = {name = 'status', type = str_type()},
20-
[3] = {name = 'utube', type = str_type()},
21-
[4] = {name = 'data', type = '*'}
18+
{name = 'task_id', type = num_type()},
19+
{name = 'status', type = str_type()},
20+
{name = 'utube', type = str_type()},
21+
{name = 'data', type = '*'}
2222
}
2323

2424
-- id, status, utube, data

‎queue/abstract/driver/utubettl.lua‎

Lines changed: 9 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -57,15 +57,15 @@ function tube.create_space(space_name, opts)
5757
space_opts.if_not_exists = if_not_exists
5858
space_opts.engine = opts.engine or 'memtx'
5959
space_opts.format = {
60-
[1] = {name = 'task_id', type = num_type()},
61-
[2] = {name = 'status', type = str_type()},
62-
[3] = {name = 'next_event', type = num_type()},
63-
[4] = {name = 'ttl', type = num_type()},
64-
[5] = {name = 'ttr', type = num_type()},
65-
[6] = {name = 'pri', type = num_type()},
66-
[7] = {name = 'created', type = num_type()},
67-
[8] = {name = 'utube', type = str_type()},
68-
[9] = {name = 'data', type = '*'}
60+
{name = 'task_id', type = num_type()},
61+
{name = 'status', type = str_type()},
62+
{name = 'next_event', type = num_type()},
63+
{name = 'ttl', type = num_type()},
64+
{name = 'ttr', type = num_type()},
65+
{name = 'pri', type = num_type()},
66+
{name = 'created', type = num_type()},
67+
{name = 'utube', type = str_type()},
68+
{name = 'data', type = '*'}
6969
}
7070

7171
-- 1 2 3 4 5 6 7, 8 9

0 commit comments

Comments
 (0)