Delete TTL tasks using delete

And add states for:

* delayed (delayed -> ready)
* TTL (* -> done)
* TTR (taken -> ready)

closes gh-51

Author: bigbes

queue/abstract.lua

@@ -432,14 +432,11 @@ end
 
 local function build_stats(space)
     local stats = {tasks = {}, calls = {
-        ack = 0,
-        bury = 0,
-        delete = 0,
-        kick = 0,
-        put = 0,
-        release = 0,
-        take = 0,
-        touch = 0
+        ack  = 0, bury  = 0, delete  = 0,
+        kick = 0, put   = 0, release = 0,
+        take = 0, touch = 0,
+        -- for *ttl queues only
+        ttl  = 0, ttr   = 0, delay   = 0,
     }}
 
     local st = rawget(queue.stat, space) or {}

queue/abstract/driver/fifottl.lua

@@ -122,7 +122,7 @@ function method._fiber(self)
                     { '=', i_status, state.READY },
                     { '=', i_next_event, task[i_created] + task[i_ttl] }
                 })
-                self:on_task_change(task)
+                self:on_task_change(task, 'delay')
                 estimated = 0
                 processed = processed + 1
             else
@@ -135,8 +135,8 @@ function method._fiber(self)
             task = self.space.index.watch:min{ state }
             if task ~= nil and task[i_status] == state then
                 if now >= task[i_next_event] then
-                    self.space:delete(task[i_id])
-                    self:on_task_change(task:transform(2, 1, state.DONE))
+                    task = self:delete(task[i_id]):transform(2, 1, state.DONE)
+                    self:on_task_change(task, 'ttl')
                     estimated = 0
                     processed = processed + 1
                 else
@@ -154,7 +154,7 @@ function method._fiber(self)
                     { '=', i_status, state.READY },
                     { '=', i_next_event, task[i_created] + task[i_ttl] }
                 })
-                self:on_task_change(task)
+                self:on_task_change(task, 'ttr')
                 estimated = 0
                 processed = processed + 1
             else

queue/abstract/driver/utubettl.lua

@@ -138,7 +138,7 @@ function method._fiber(self)
                     { '=', i_status, state.READY },
                     { '=', i_next_event, task[i_created] + task[i_ttl] }
                 })
-                self:on_task_change(task)
+                self:on_task_change(task, 'delayed')
                 estimated = 0
                 processed = processed + 1
             else
@@ -151,8 +151,8 @@ function method._fiber(self)
             task = self.space.index.watch:min{ state }
             if task ~= nil and task[i_status] == state then
                 if now >= task[i_next_event] then
-                    self.space:delete(task[i_id])
-                    self:on_task_change(task:transform(2, 1, state.DONE))
+                    task = self:delete(task[i_id]):transform(2, 1, state.DONE)
+                    self:on_task_change(task, 'ttl')
                     estimated = 0
                     processed = processed + 1
                 else
@@ -170,7 +170,7 @@ function method._fiber(self)
                     { '=', i_status, state.READY },
                     { '=', i_next_event, task[i_created] + task[i_ttl] }
                 })
-                self:on_task_change(task)
+                self:on_task_change(task, 'ttr')
                 estimated = 0
                 processed = processed + 1
             else