Ecosyste.ms: OpenCollective

An open API service for software projects hosted on Open Collective.

github.com/hibiken/asynq

Simple, reliable, and efficient distributed task queue in Go
https://github.com/hibiken/asynq

Add test for (*rdb).kill

da0bfa15192b7c91b6b9d127a4b3f3b5f15e610e authored about 5 years ago by Ken Hibino <[email protected]>
Refactor rdb tests

481d3c6b770e17563458e81259ffff39eac1e1f3 authored about 5 years ago by Ken Hibino <[email protected]>
Add test for (*rdb).remove

e5e3fee742ba492f90e3a3de20a4cb078ca541dc authored about 5 years ago by Ken Hibino <[email protected]>
Rename (*rdb).lrem to (*rdb).remove

1617278d864b6611b766e8aedfe28e52443ab63b authored about 5 years ago by Ken Hibino <[email protected]>
Clean up error messages from rdb methods

efaceb8a0373afd8a7f4c21a5f6cd0b641a6b994 authored about 5 years ago by Ken Hibino <[email protected]>
Minor cleanup

c9a8f5fabd0e714c66772fb6da637afcb52e9781 authored about 5 years ago by Ken Hibino <[email protected]>
fix:Remove task from in_progress when worker goroutine finishes

There was a bug related to the logic of removing task from
"asynq:in_progress" list when worker ...

0db4b8a34f97ac8fefba3c91dbb75ed6244aba18 authored about 5 years ago by Ken Hibino <[email protected]>
Merge pull request #3 from hibiken/feature/recover

Protect handler call against panic

871162cd673385f645e6b24982fc19b2cdcf070a authored about 5 years ago by Ken Hibino <[email protected]>
Protect handler call against panic

d4f136ebc9ae9f37395c9861a0c1b98472695c9c authored about 5 years ago by Ken Hibino <[email protected]>
Rename (*rdb).zadd to (*rdb).schedule

47e2a57d05adc44125b6c44849a8dc4606327bee authored about 5 years ago by Ken Hibino <[email protected]>
Change newRDB signature

fab2dcb56ea0e772de06d62e1b12f11597aba1aa authored about 5 years ago by Ken Hibino <[email protected]>
Update log messages on shutdown

e6b1230c363dc0e5df4008aa8d2b99a6521b6afe authored about 5 years ago by Ken Hibino <[email protected]>
Minor cleanup

60132f3208ff5af7ee39db2b241d51255bf78f5e authored about 5 years ago by Ken Hibino <[email protected]>
Merge pull request #2 from hibiken/feature/lua

Use Lua script to make multiple redis commands atomic

d35d345e2d1651aba4272a28c96c309d4178c7d5 authored about 5 years ago by Ken Hibino <[email protected]>
Use lua script to implement (*rdb).moveAll

97b96f6992a477f25b86b5af8340ae6218a38c67 authored about 5 years ago by Ken Hibino <[email protected]>
Refactor (*rdb).moveAll test

4fd82c59754a4027d5f11637125bda3d5eb4b9f9 authored about 5 years ago by Ken Hibino <[email protected]>
Use (*rdb).forward in poller

d2a6cc127d5fc6980d27b26f27408f4717c8c413 authored about 5 years ago by Ken Hibino <[email protected]>
Refactor (*rdb).forward test

cff5e67018911026692ce7dee2fe672b25bfe1f9 authored about 5 years ago by Ken Hibino <[email protected]>
Refactor dequeue test

810c40bd54be2b509e0651e4378c54261f57a7cf authored about 5 years ago by Ken Hibino <[email protected]>
Use pipeline for enqueue

199dcf8fdb89d030e0cb6b0bea59c0879e6d77f7 authored about 5 years ago by Ken Hibino <[email protected]>
Rename (*rdb).push to enqueue

faa9b6ee22a6d1a0efbda2c6d422dea36234b5a8 authored about 5 years ago by Ken Hibino <[email protected]>
Refactor rdb_test.go

737de898ebfc51cb848c1341b230f925c41d79fe authored about 5 years ago by Ken Hibino <[email protected]>
Add (*rdb).forward method using lua script

4aa5078dc45e95bf680685f9109fce92f5d74bbd authored about 5 years ago by Ken Hibino <[email protected]>
Add DB field to RedisOpt to specify redis db index

f91004e6aa876841a89b6fff642a4594aead75ee authored about 5 years ago by Ken Hibino <[email protected]>
Follow the convention of declaring variable immediately after its guard

mutex

d5c2b9b9954e2640e4f18d671b201fd9c585fada authored about 5 years ago by Ken Hibino <[email protected]>
fix: Nil out handler reference after all workers have finished

5eaf606a0d7e5e999c19ba54ac332a33dfef74a4 authored about 5 years ago by Ken Hibino <[email protected]>
Update comments

ac3190a0d590c5d98c59f616cb1766d155829815 authored about 5 years ago by Ken Hibino <[email protected]>
Simplify Background API

be3b774b5194b7756acfb52dd76cbc97a1360be5 authored about 5 years ago by Ken Hibino <[email protected]>
Rename Launcher to Background

e19c45cff31fc518e54bb6bbcf263c4bb460b369 authored about 5 years ago by Ken Hibino <[email protected]>
Merge pull request #1 from hibiken/feature/simple_rescue

Rescue dead "In Progress" tasks

847d72498520aa0df77538d972b61db5399fe351 authored about 5 years ago by Ken Hibino <[email protected]>
Add logic to restore unfinished tasks back into the default queue if

there are any uncompleted tasks

fd80126a6756bd6cefa56557ba4a8875ee9d3784 authored about 5 years ago by Ken Hibino <[email protected]>
Use command BRPUSHLPOP to move from queue to in_progress in redis

4a327933bdd17725bdfd4703df7ec6bdcf472954 authored about 5 years ago by Ken Hibino <[email protected]>
Change the direction of list push/pop operations

76ceb282a906a40e23e9c05a3e8852584fc5bcfe authored about 5 years ago by Ken Hibino <[email protected]>
Remove per task heartbeat

3fa867b190bc713efe316a0afb0a72f6fc4ef031 authored about 5 years ago by Ken Hibino <[email protected]>
Add heartbeat goroutine to write heartbeat data to redis for active

worker

2e0af11ca0a5c1ec6dced5cc7a4ce1e5912c1a87 authored about 5 years ago by Ken Hibino <[email protected]>
Add ID field to taskMessage

80f477212d3f66459fa6fe4b257d5a24eb46f382 authored about 5 years ago by Ken Hibino <[email protected]>
Track in-progress tasks with redis SET

67a9e8aa001a7e8b504c681cd5ed00b423d25336 authored about 5 years ago by Ken Hibino <[email protected]>
Minor fixes

c84287d7ab00a7c04bc5d133d999fab0e1f3d299 authored about 5 years ago by Ken Hibino <[email protected]>
Move retry related logic to its own file

66930970f93845499204edd903785e0ec66c80ce authored about 5 years ago by Ken Hibino <[email protected]>
Minor cleanup

3dddcfbb142f3971a3a58a35a92c8122fc194b2e authored about 5 years ago by Ken Hibino <[email protected]>
Rename manager to processor

2dd5f2c5abe8597dbcc625348910e951e18c4ab5 authored about 5 years ago by Ken Hibino <[email protected]>
Add tests for type rdb

dd0b0b358c6a952bd1c79e06002666a8b07c8131 authored about 5 years ago by Ken Hibino <[email protected]>
Move client and launcher to its own files

e9069bfb47f13112af6a52a429995f4693ac2dea authored about 5 years ago by Ken Hibino <[email protected]>
Extract redis logic to type rdb

85a04cbabb642b58fa573aaefe02011ec827a0e6 authored about 5 years ago by Ken Hibino <[email protected]>
Update todo comments

4c5b6081de2f6e488e7a072909f23d26a3819ae2 authored about 5 years ago by Ken Hibino <[email protected]>
Make Launcher thread safe

eb6a5032f60e8292d514bbadbc6df716d3e18d7f authored about 5 years ago by Ken Hibino <[email protected]>
Gracefully shutdown all scheduled goroutines on (*Launcher).Stop

e238d3835dd6532e2b0351c24c2d29efe85b6da1 authored about 5 years ago by Ken Hibino <[email protected]>
Extract manager to its own type

195fd893be2246da16d75c24481150389ff3b05f authored about 5 years ago by Ken Hibino <[email protected]>
Change (*poller).start to use time.Sleep instead of ticker

8d22d1f6fb548e65bfe9f781b04a7e59b4297206 authored about 5 years ago by Ken Hibino <[email protected]>
Rename Workers to Launcher

89c54fb47d1c2da9aeaa84c721eb1eb9a5880ea2 authored about 5 years ago by Ken Hibino <[email protected]>
Extract polling logic to poller type

4485b6e3a98d3b4bcc2339bac39de47bf2cc01c0 authored about 5 years ago by Ken Hibino <[email protected]>
Fix bug around releasing semaphore token

3daef02632e706f65792f17e2c3d8048e1410d0a authored about 5 years ago by Ken Hibino <[email protected]>
Make Run method stateful

c6f482d4f868092a132d93b2edc3506eda9e2ff8 authored about 5 years ago by Ken Hibino <[email protected]>
Send retry exhausted tasks to "dead" zset

62db9863fbe4caf9c0cce45cb9dbac8413bdebc2 authored about 5 years ago by Ken Hibino <[email protected]>
Implement exponential backoff retry

6252cc02e00309feec3ca053728afd95895330a4 authored about 5 years ago by Ken Hibino <[email protected]>
Add retry logic

22e2a6f43369d3742e1801cb6e506eee803ef3e7 authored about 5 years ago by Ken Hibino <[email protected]>
Change internal representation of task data written to redis

e75756937e468e75b38c627c6281e26207295cac authored about 5 years ago by Ken Hibino <[email protected]>
Change package APIs

d2d0d1fde5746c4f2d597c8caba27ae90f15e598 authored about 5 years ago by Ken Hibino <[email protected]>
Add support for multiple queues

f4d59bece747fd4d6cd80a3340184d0c8126235e authored about 5 years ago by Ken Hibino <[email protected]>
Extract a push logic to a function

95023bd3b5af5c00bc52c18f33e42e40aaf8a89e authored about 5 years ago by Ken Hibino <[email protected]>
Refactor enqueue logic for scheduled tasks

bda718bcaa955f4969823dc9e2cb17fafa2b5929 authored about 5 years ago by Ken Hibino <[email protected]>
Add workers

e362e0dacac4751528dc14be6019464494d7fed6 authored about 5 years ago by Ken Hibino <[email protected]>
Initial commit

6d65ebfb35fd8e6878ab9d885aadce837262fca6 authored about 5 years ago by Ken Hibino <[email protected]>