queue
queue copied to clipboard
tarantool
Create task queues, add and take jobs, monitor failed tasks
Temporary working directories created and cleaned inside tarantool session. This causes tarantool to recreate the working directory on exit. Files left after running one test: ``` sh $ find /tmp...
Example: - Worker takes a task - Run `package.reload()` - [Task is released back to ready state](https://github.com/tarantool/queue/blob/cede9456e27ed695e865274b44768d5416e6e128/queue/abstract.lua#L581). - Worker cannot ack task https://github.com/tarantool/queue/issues/66 https://github.com/tarantool/queue/pull/106
When releasing/deleting a task in utubettl, the code finds a "neighbour" task - a task with the same utube field that is in READY state. It then notifies the framework...
```lua 1 local function build_stats(space) 2 local stats = {tasks = {}, calls = { 3 ack = 0, bury = 0, delete = 0, 4 kick = 0, put...
The take() method in utubettl does a linear search for a task from an available utube. In case there are many tasks in the same utube, calling take() will result...
Please update information about supported tarantool versions
Consider following case: Few (let's say 3) nodes in a cluster, with master-master replication. Each node has it's own queue with name, unique in cluster. As each tube need to...
There is no mention of `tube:grant()` in the README.
Consider adding a new method to insert multiple tasks atomically (all or none). The method's signature may look like the following: ```lua tube:put_many({ {task_data1 [, options1]} [, {task_data2 [, options2]}...