Fix queue spaces formats

Author: igorcoding

queue/abstract.lua

@@ -444,11 +444,11 @@ function method.start()
     if _queue == nil then
         _queue = box.schema.create_space('_queue', {
             format = {
-                [1] = {name = 'tube_name', type = str_type()},
-                [2] = {name = 'tube_id', type = num_type()},
-                [3] = {name = 'space_name', type = str_type()},
-                [4] = {name = 'tube_type', type = str_type()},
-                [5] = {name = 'opts', type = '*'}
+                {name = 'tube_name', type = str_type()},
+                {name = 'tube_id', type = num_type()},
+                {name = 'space_name', type = str_type()},
+                {name = 'tube_type', type = str_type()},
+                {name = 'opts', type = '*'}
             }
         })
         _queue:create_index('tube', {
@@ -469,11 +469,11 @@ function method.start()
         _cons = box.schema.create_space('_queue_consumers', {
             temporary = true,
             format = {
-                [1] = {name = 'session_id', type = num_type()},
-                [2] = {name = 'fiber_id', type = num_type()},
-                [3] = {name = 'tube_id', type = num_type()},
-                [4] = {name = 'event_time', type = num_type()},
-                [5] = {name = 'fiber_time', type = num_type()}
+                {name = 'session_id', type = num_type()},
+                {name = 'fiber_id', type = num_type()},
+                {name = 'tube_id', type = num_type()},
+                {name = 'event_time', type = num_type()},
+                {name = 'fiber_time', type = num_type()}
             }
         })
         _cons:create_index('pk', {
@@ -494,10 +494,10 @@ function method.start()
         _taken = box.schema.create_space('_queue_taken', {
             temporary = true,
             format = {
-                [1] = {name = 'session_id', type = num_type()},
-                [2] = {name = 'tube_id', type = num_type()},
-                [3] = {name = 'task_id', type = num_type()},
-                [4] = {name = 'taken_time', type = num_type()}
+                {name = 'session_id', type = num_type()},
+                {name = 'tube_id', type = num_type()},
+                {name = 'task_id', type = num_type()},
+                {name = 'taken_time', type = num_type()}
             }})
         _taken:create_index('pk', {
             type = 'tree',

queue/abstract/driver/fifo.lua

@@ -14,9 +14,9 @@ function tube.create_space(space_name, opts)
     space_opts.if_not_exists = if_not_exists
     space_opts.engine        = opts.engine or 'memtx'
     space_opts.format = {
-        [1] = {name = 'task_id', type = num_type()},
-        [2] = {name = 'status', type = str_type()},
-        [3] = {name = 'data', type = '*'}
+        {name = 'task_id', type = num_type()},
+        {name = 'status', type = str_type()},
+        {name = 'data', type = '*'}
     }
 
     local space = box.schema.create_space(space_name, space_opts)

queue/abstract/driver/fifottl.lua

@@ -55,14 +55,14 @@ function tube.create_space(space_name, opts)
     space_opts.if_not_exists = if_not_exists
     space_opts.engine        = opts.engine or 'memtx'
     space_opts.format = {
-        [1] = {name = 'task_id', type = num_type()},
-        [2] = {name = 'status', type = str_type()},
-        [3] = {name = 'next_event', type = num_type()},
-        [4] = {name = 'ttl', type = num_type()},
-        [5] = {name = 'ttr', type = num_type()},
-        [6] = {name = 'pri', type = num_type()},
-        [7] = {name = 'created', type = num_type()},
-        [8] = {name = 'data', type = '*'}
+        {name = 'task_id', type = num_type()},
+        {name = 'status', type = str_type()},
+        {name = 'next_event', type = num_type()},
+        {name = 'ttl', type = num_type()},
+        {name = 'ttr', type = num_type()},
+        {name = 'pri', type = num_type()},
+        {name = 'created', type = num_type()},
+        {name = 'data', type = '*'}
     }
 
     -- 1        2       3           4    5    6    7,       8

queue/abstract/driver/utube.lua

@@ -15,10 +15,10 @@ function tube.create_space(space_name, opts)
     space_opts.if_not_exists = if_not_exists
     space_opts.engine        = opts.engine or 'memtx'
     space_opts.format = {
-        [1] = {name = 'task_id', type = num_type()},
-        [2] = {name = 'status', type = str_type()},
-        [3] = {name = 'utube', type = str_type()},
-        [4] = {name = 'data', type = '*'}
+        {name = 'task_id', type = num_type()},
+        {name = 'status', type = str_type()},
+        {name = 'utube', type = str_type()},
+        {name = 'data', type = '*'}
     }
 
     -- id, status, utube, data

queue/abstract/driver/utubettl.lua

@@ -57,15 +57,15 @@ function tube.create_space(space_name, opts)
     space_opts.if_not_exists = if_not_exists
     space_opts.engine        = opts.engine or 'memtx'
     space_opts.format = {
-        [1] = {name = 'task_id', type = num_type()},
-        [2] = {name = 'status', type = str_type()},
-        [3] = {name = 'next_event', type = num_type()},
-        [4] = {name = 'ttl', type = num_type()},
-        [5] = {name = 'ttr', type = num_type()},
-        [6] = {name = 'pri', type = num_type()},
-        [7] = {name = 'created', type = num_type()},
-        [8] = {name = 'utube', type = str_type()},
-        [9] = {name = 'data', type = '*'}
+        {name = 'task_id', type = num_type()},
+        {name = 'status', type = str_type()},
+        {name = 'next_event', type = num_type()},
+        {name = 'ttl', type = num_type()},
+        {name = 'ttr', type = num_type()},
+        {name = 'pri', type = num_type()},
+        {name = 'created', type = num_type()},
+        {name = 'utube', type = str_type()},
+        {name = 'data', type = '*'}
     }
 
     -- 1        2       3           4    5    6    7,       8      9