release

README.md

@@ -26,27 +26,26 @@ Config.tarantool = {
     wal_dir           = './',
     background        = false,
     custom_proc_title = 'qube',
-    -- log_format        = 'json'
   }
 }
 
 -- HTTP Server
 Config.http = {
   root         = '/api/v1',
   host         = '127.0.0.1',
-  port         = 5672,
+  port         = '5672',
   token        = '77c04ced3f915240d0c5d8d5819f84c7',
   log_requests = true,
   log_errors   = true
 }
 
--- Shipper (push tasks back to app)
+-- Shipper
 Config.shipper = {
-  enable       = true,
-  user_agent   = 'QubeShipper',
-  token        = '77c04ced3f915240d0c5d8d5819f84c7',
-  webhook_url  = 'http://localhost:3000/qube/_jobs',
-  task_check   = 1
+  enable      = true,
+  user_agent  = 'QubeShipper',
+  token       = '77c04ced3f915240d0c5d8d5819f84c7',
+  webhook_url = 'http://localhost:3000/_jobs',
+  delay       = 0
 }
 ```
 

config.lua

@@ -8,14 +8,12 @@ Config.tarantool = {
   },
   node = {
     pid_file          = './tmp/qube.pid',
-    -- pid_file          = '/var/run/qube.pid',
     memtx_memory      = 1024 * 1024 * 1024 * 1,
     memtx_dir         = './tmp',
     wal_dir           = './tmp',
     background        = false,
     custom_proc_title = 'qube',
     log_level         = 5,
-    -- log_format        = 'json'
   }
 }
 

lib/shipper.lua

@@ -49,7 +49,6 @@ function M.sender_worker()
   while true do
     if M.transport.tunnel:is_empty() then
       logger.debug('Sender: channel is empty')
-      fiber.testcancel()
       fiber.sleep(config.shipper.delay)
     else
       local task = M.transport.tunnel:get(0)
@@ -73,7 +72,6 @@ function M.sender_worker()
       else
         logger.error('Sender: failed to shipped task: ' .. tostring(push_err))
       end
-      fiber.testcancel()
       fiber.sleep(config.shipper.delay)
     end
   end
@@ -98,7 +96,6 @@ function M.finder_worker()
         logger.verbose('Finder: waiting for new task...')
       end
     end
-    fiber.testcancel()
     fiber.sleep(config.shipper.delay)
   end
 end
@@ -113,7 +110,6 @@ function M.start()
     local sender = M.transport.sender
     sender.fb = fiber.create(M.sender_worker)
     sender.fb:name('sender')
-
     return true
   else
     logger.error('Failed to start workers')