queue
queue copied to clipboard
tarantool
Create task queues, add and take jobs, monitor failed tasks
The number of requests has increased significantly аfter installation of queue module. I use tarantool for data cache and when the client disconnects, the queue creates a new session and...
A new type of space has been added to the tarantool's master: https://github.com/tarantool/tarantool/commit/70e423e92fc00df2ffe385f31dae9ea8e1cc1732 `create_tube` method allows you to create temporary tubes, but this functionality is disabled for replicaset mode: ```lua...
https://github.com/tarantool/queue/blob/ea8449b6fa06c373124cee0530e71c7fd7a11c78/queue/abstract/driver/fifo.lua#L70-L73 > To minimize the possibility of conflicts, MVCC uses what is called best-effort visibility: for write transactions it chooses read-committed, for read transactions it chooses read-confirmed. by default task_id:max...
I don't have a stable [test](https://github.com/tarantool/go-tarantool/blob/0ffd926e219c543fa95f36c7aec25f729749e371/queue/example_connection_pool_test.go#L112-L222) results if `queue.cfg({in_replicaset = true})` is called after `box.cfg()`. I have such errors on re-identify after a role switch: ``` Unable to re-identify in...
If some of the utubes for tasks at the start of the queue were busy most of the time, `take` would slow down for every other task. This problem is...
Our clients reported that `utubettl:take()` loads CPU too much and takes too much time when there is a `utube` with a big amount of tasks (+100.000). * We need a...
In case of a transaction conflict for 'vinyl' we need to retry an entire transaction. Part of #230
This issue will become relevant after merging this PR: https://github.com/tarantool/queue/pull/229 Right now new `STORAGE_MODE_UTUBE_READY_SPACE` storage mode for `utube` and `utubettl` implemented only for `memtx` engine. With `vinyl` there is a...
`kick` method is used to unbury several tasks in the tube. After analyzing this method for drivers `fifo`, `fifottl`, `utube`, `utubettl`, I came to the conclusion, that it still possible...
The `queue_name_ready_buffer` does not have user grants like regular spaces: https://github.com/tarantool/queue/blob/df24f171690e9128e94d4ced938cebd8a547eadb/queue/abstract.lua#L349