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

Allow user to define a max retry count for a task

4229073a249f5b54a6acd9045bc371293c44a3ef authored about 5 years ago by Ken Hibino <[email protected]>
Update CLI description

fc66aaa47fdba9ed4836b9b1960db4bc6170d4b8 authored about 5 years ago by Ken Hibino <[email protected]>
Merge pull request #18 from hibiken/feature/payload

Better Payload API

6df302689ce82ceea98ec83cbff13be4c76f9565 authored about 5 years ago by Ken Hibino <[email protected]>
Add Hash method to Payload

324a785233aa56d6920209bdd411a01cede67089 authored about 5 years ago by Ken Hibino <[email protected]>
Add Get* methods to Payload type

14ac5f6674083b3a32c2d480fb86e56a4cdebf39 authored about 5 years ago by Ken Hibino <[email protected]>
[ci skip] Update todos

3fd096a90ae0765648cedfd2cb8b19416f6d2195 authored about 5 years ago by Ken Hibino <[email protected]>
Merge pull request #17 from hibiken/feature/stop

Implement better signal handling

bc7991c7576a6baa2bf49d080158b54efcfaa6c3 authored about 5 years ago by Ken Hibino <[email protected]>
Rename channel name

8b98b6e5a04ef358c5d50d8c5fdbe1a39f6ca93c authored about 5 years ago by Ken Hibino <[email protected]>
Log warning and info messages when unfinished tasks get aborted

33e9da953d3d00b2c4c0c8a45955c26552094988 authored about 5 years ago by Ken Hibino <[email protected]>
[ci skip] Update todos

b2bc0ef91ce2c0cc676b9d82cc4e0104a84fdde3 authored about 5 years ago by Ken Hibino <[email protected]>
Use sync.Once

69b46a7f0d07d09def6277ec0c6e788c78471bc0 authored about 5 years ago by Ken Hibino <[email protected]>
Modify poller to wait for Time.After channel instead of time.Sleep

c40e779fdb4387bc0351f9bfe98dc271a3ee1937 authored about 5 years ago by Ken Hibino <[email protected]>
Unblock processor shutdown process if processor is waiting for semaphore

token

5ddba8ca981e5e8ddf361fca31c3bbf3cabe1eef authored about 5 years ago by Ken Hibino <[email protected]>
Stop processing more tasks from the queue once TSTP signal is received

24dd78b31c2be16c2e2c2619cdfd58ce721220bc authored about 5 years ago by Ken Hibino <[email protected]>
Trap and handle TSTP signal

3e30c5916b91434155dca060503b4d68c03705f8 authored about 5 years ago by Ken Hibino <[email protected]>
Terminate background upon receiving SIGTERM or SIGINT

911e600c41b8318c690f887ec29c9fd5ed5a5d32 authored about 5 years ago by Ken Hibino <[email protected]>
Merge pull request #16 from hibiken/feature/signals

Add timeout to shutdown when TERM signal is received

12fc336889acea9476b6d33d7c77f5395244657c authored about 5 years ago by Ken Hibino <[email protected]>
[ci skip] Update todos

bcaccf11745a250724f03dfbefed4a243cd12ac7 authored about 5 years ago by Ken Hibino <[email protected]>
Fix: Use buffered channel of size 1 to avoid goroutine leaks

eb3216d35440076d16b2d7ff9973fc7c5dcd802b authored about 5 years ago by Ken Hibino <[email protected]>
Add timeout to worker goroutines when TERM signal is received

Wait for a certain amount of time to allow for worker goroutines to
finish. If the goroutines do...

989b2b6d559df30b1f526b6f6eb73cc78e45fb63 authored about 5 years ago by Ken Hibino <[email protected]>
Fix: Do not use lua cjson library to encode task to json

Go and Lua json libraries encodes json differently (e.g. order of
key/value) and caused a bug wh...

e5686894d3da77e92a8a293a9ae51b7b9ed0977a authored about 5 years ago by Ken Hibino <[email protected]>
Remove (*RDB).RetryLater in favor of Retry method

442b33a6d2c6db10726cd85681453bfdbd09d731 authored about 5 years ago by Ken Hibino <[email protected]>
Modify (*RDB).Kill method to atomically move task from in_progress to

dead queue

d84e8c0ff26f5629b7f958296fc6e497d43366e9 authored about 5 years ago by Ken Hibino <[email protected]>
Add Retry method to *RDB

(*RDB).Retry method takes a TaskMessage and will atomically moves the
message from in_progress q...

1b1662bb12f98e3dcdf17d555ce14a98d07b8e79 authored about 5 years ago by Ken Hibino <[email protected]>
Merge pull request #15 from hibiken/refactor/testing

Refactor tests

1857d12cea3af1f484da3d7d918a1538eea23ac3 authored about 5 years ago by Ken Hibino <[email protected]>
Clean up rdb package tests

04836194f93e407f83975ccc9e7b6ed12eff4bc3 authored about 5 years ago by Ken Hibino <[email protected]>
Rename randomTask test helper to newTaskMessage

9410a65338c59e0be64ceae8bcbb0900ea57a3e0 authored about 5 years ago by Ken Hibino <[email protected]>
[ci skip] Update todos

d2eeaf6ab1b9746e6b7b6f0fb368f926bbb1dd13 authored about 5 years ago by Ken Hibino <[email protected]>
Merge pull request #14 from hibiken/feature/delall

Add delall command to asynqmon CLI

0620f2f0f7947586a420c654257b54ac73a8f925 authored about 5 years ago by Ken Hibino <[email protected]>
Add delall command to asynqmon CLI

b7870548d38dc5e19895500a16813da2ca22e452 authored about 5 years ago by Ken Hibino <[email protected]>
Add DeleteAll* methods to rdb

ca31cbf8435b3412cd8be21b8bcd461da79d9b8c authored about 5 years ago by Ken Hibino <[email protected]>
Merge pull request #13 from hibiken/feature/del

Add del command to asynqmon CLI

9d79861ac0fae27a2104d7857acd7f7b085c25ef authored about 5 years ago by Ken Hibino <[email protected]>
Add del command to asynqmon CLI

1a687bbf840486f0077e66da6952fee6769e7f6d authored about 5 years ago by Ken Hibino <[email protected]>
Add delete methods to rdb

be746d01a5fbb34d741baeefdeccd27ccea2fa31 authored about 5 years ago by Ken Hibino <[email protected]>
Merge pull request #12 from hibiken/feature/shorter_id

Use rs/xid package for more compact string representation of task IDs

193d27d93dccc8f735a48ebef2613f48351f32b5 authored about 5 years ago by Ken Hibino <[email protected]>
Replace google/uuid package with rs/xid for more compact id

edcd70b2212aa6e5067511ab45fc0d679bb8e0e6 authored about 5 years ago by Ken Hibino <[email protected]>
[ci skip] Update todos

8b6e3172ce6771391895a2ea7b56e15176ed4465 authored about 5 years ago by Ken Hibino <[email protected]>
Merge pull request #11 from hibiken/feature/enqall

Add enqall command to asynqmon CLI

542b7867d85a90a125ed3df61f704b07121e9d84 authored about 5 years ago by Ken Hibino <[email protected]>
Minor improvement

ef562e2efabb8047b72e81880d51f0726ca4b3b1 authored about 5 years ago by Ken Hibino <[email protected]>
Add enqall command to asynqmon CLI

a96719413c54f433472e18cb1bf4a6fef059a182 authored about 5 years ago by Ken Hibino <[email protected]>
Add methods to rdb to enqueue all tasks from dead, retry and scheduled

queue

0d74c518bfe928ad076c72c64f1b37d54619bcba authored about 5 years ago by Ken Hibino <[email protected]>
Merge pull request #10 from hibiken/feature/enq

Add enq command to asynqmon CLI

c0185061eb6107f63898e936d97287bd57c8e2f1 authored about 5 years ago by Ken Hibino <[email protected]>
Minor improvement

ea28d3cac1c2ea6392353644e8422b04c6093b44 authored about 5 years ago by Ken Hibino <[email protected]>
Rename rdb methods to enqueue scheduled, retry, and dead tasks

8830d2338897686db1e4224c2782d30742136f86 authored about 5 years ago by Ken Hibino <[email protected]>
[ci skip] Update documentations for enq command

b766de4f1800596feb48a10d3b2d26621ce255d9 authored about 5 years ago by Ken Hibino <[email protected]>
[ci skip] Update todos

764edc35e3938b8a8f20a6fc5752d27d26fcc85b authored about 5 years ago by Ken Hibino <[email protected]>
Minor improvement

8932ca41b3f29a8aa997346f6be24fe7fc3f628e authored about 5 years ago by Ken Hibino <[email protected]>
Add enq command to asynqmon

4179c72c05b38d329dce97dfece5e8370b8042c1 authored about 5 years ago by Ken Hibino <[email protected]>
Merge pull request #9 from hibiken/feature/rescue

Add methods to RDB to enqueue a task sitting in ZSET (scheduled, retry, dead).

39c4904dae1c8f71a9aa4ab5464df9213d6215e0 authored about 5 years ago by Ken Hibino <[email protected]>
[ci skip] Fix typos

bbd8fb901f60d5af9750fb82014cb0015884e1a7 authored about 5 years ago by Ken Hibino <[email protected]>
Add methods to rdb.RDB to enqueues a task from scheduled, retry, dead

queues

680a2cf3dfe735c0a432c04076516f60b6f30ae9 authored about 5 years ago by Ken Hibino <[email protected]>
Update todos

8e2c4e571602783a31569c7ad8dc129b046731e0 authored about 5 years ago by Ken Hibino <[email protected]>
Merge pull request #8 from hibiken/feature/tools

Use cobra for asynqmon CLI

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

9941c9e3033f1a286d8dbb264408e82961384cbc authored about 5 years ago by Ken Hibino <[email protected]>
Remove cobra comments

2951cc355fc1af776b4c6056f42d88e2ab18f5ee authored about 5 years ago by Ken Hibino <[email protected]>
Fix readme

0382fc1d08db239b3ee400c8ac0a625d0ad99173 authored about 5 years ago by Ken Hibino <[email protected]>
Add ls command to asynqmon

ad01341c735b37509b0b083aa525321299c91a5c authored about 5 years ago by Ken Hibino <[email protected]>
Remove debug log

c1d049718279b659892d6fdbea65cd17c9519d1f authored about 5 years ago by Ken Hibino <[email protected]>
Use cobra for tools

b749d8bd34b7dfb22dbc7220d8f4a1532d7f5ccd authored about 5 years ago by Ken Hibino <[email protected]>
Add flags to stats command

62fb3cf7d98d2590b3ccd3e3903c8a4bf435cd8e authored about 5 years ago by Ken Hibino <[email protected]>
Change cmd dir to tools

5c2cb917e1b208b2742c8d151c2c9e87186a73fb authored about 5 years ago by Ken Hibino <[email protected]>
Merge pull request #7 from hibiken/feature/doc

Add package documentation

e658f04648dae935790e304ba3210cc26bc2ff2c authored about 5 years ago by Ken Hibino <[email protected]>
Update exported package API docs

aa8a3b8aaa7c927a738bc2c0682970b2c5868701 authored about 5 years ago by Ken Hibino <[email protected]>
Add doc.go for package documentation

46e84769b5316371a13199953cd08ffdb2be47f5 authored about 5 years ago by Ken Hibino <[email protected]>
Update todos

20ad6daa6ee99e55b7eefbdb92916d7ea971b38a authored about 5 years ago by Ken Hibino <[email protected]>
Merge pull request #6 from hibiken/refactor/internalpkg

Create internal package for reuse

3d72ca5a74a0d98e93473046ea91a79ffb00112b authored about 5 years ago by Ken Hibino <[email protected]>
Update asynqmon

562667000712c073f395c4ae5b6f02d0c4d4ce31 authored about 5 years ago by Ken Hibino <[email protected]>
Add tests for rdb list methods

f3b974522804be212dbafbc10b978f1569b5aa4f authored about 5 years ago by Ken Hibino <[email protected]>
Unexport redis key name constants from rdb package

437fb03bb38cca514cb194c4f333580ce9aab804 authored about 5 years ago by Ken Hibino <[email protected]>
Implement all "list tasks" methods in rdb

918f33d37d14dc9737f5b7337bf9d763b2ac08fb authored about 5 years ago by Ken Hibino <[email protected]>
Minor improvements

afacc319909c8b1c09557da5540b9b09a9c3493d authored about 5 years ago by Ken Hibino <[email protected]>
Use different redis db for each package tests

998e761660936208d3bcced59497ef5a646edabe authored about 5 years ago by Ken Hibino <[email protected]>
Rename to CheckAndEnqueue

28bfb6d83a2b007ec43b2045646e72ffdc9a023b authored about 5 years ago by Ken Hibino <[email protected]>
Fix monitor command

af1dcf5044be0f9093c158372b0f214d2539caaa authored about 5 years ago by Ken Hibino <[email protected]>
Refactor forwarding of scheduled tasks

4684f961c06a82bb9b920f4e6219d51aaee14282 authored about 5 years ago by Ken Hibino <[email protected]>
Rename MoveAll to RestoreUnfinished

318b24b3b8b8fd3a002ea9d3d24a9601b1318faf authored about 5 years ago by Ken Hibino <[email protected]>
Define Schedule and RetryLater method for RDB

4531e90b9d0df0625bbb4b3b5947bd6c2585a9f0 authored about 5 years ago by Ken Hibino <[email protected]>
Rename rdb Remove to Done

985018e1b5ccc189ae00c616869e7e7bdb0636a4 authored about 5 years ago by Ken Hibino <[email protected]>
Change rdb Dequeue signature

39f177dabff40c12a83de1fa01cd458d2042fd76 authored about 5 years ago by Ken Hibino <[email protected]>
Extract rdb to internal package

d4e442d04fafd1bbf06501c07aeef51438ae17df authored about 5 years ago by Ken Hibino <[email protected]>
Add command "asynqmon" for monitoring

593f2b04824f6cb5356f7cbd04c1c86916c4dc75 authored about 5 years ago by Ken Hibino <[email protected]>
Add List* methods to Inspector

5446f877ceb7118862109313cc88133600224136 authored about 5 years ago by Ken Hibino <[email protected]>
Change inspector's list methods to return specific task type for each

queue

319d157d47f4b8d34e2022e29735bef7183345e0 authored about 5 years ago by Ken Hibino <[email protected]>
Create Inspector

9c2d2a612dbde6f14daef4270600fe569a42396d authored about 5 years ago by Ken Hibino <[email protected]>
Add task types specific to each queue

28dae0fdd35064971a91afb6efec9256be27e0bf authored about 5 years ago by Ken Hibino <[email protected]>
Rename to RedisConfig

57838600ef2904c2758c8d2b1850f1beae0037e0 authored about 5 years ago by Ken Hibino <[email protected]>
Merge pull request #5 from hibiken/api/handler

Change Background to take Handler interface

4afb3a2401154e001b4846fa3deecf7ee9cc44fc authored about 5 years ago by Ken Hibino <[email protected]>
Change Background API to take Handler interface

b0a54cd2b2962c4be0d5cd677ce61e5a4256b097 authored about 5 years ago by Ken Hibino <[email protected]>
Update readme

1a996e0d403326fcd18bf9935e5ffdfcef6807ed authored about 5 years ago by Ken Hibino <[email protected]>
Add MIT License

1a97d4ba98ca91ff414a4e587047823f90d2133f authored about 5 years ago by Ken Hibino <[email protected]>
Add readme

b9cb95b1e15b2c75ccf61775f146c569cea6bdf5 authored about 5 years ago by Ken Hibino <[email protected]>
Add .travis.yml

d31532c8f59b657c09b55f4675bafaeb25ee7a8c authored about 5 years ago by Ken Hibino <[email protected]>
Move test helpers to asynq_test.go

8eb6f04ef4afa6512cb980ef446833d9fd011110 authored about 5 years ago by Ken Hibino <[email protected]>
Add test for background to verify no goroutine leaks

ad1291e0a1b3e3bcd531a6a3b68b95e1e6497ebe authored about 5 years ago by Ken Hibino <[email protected]>
Update todos

09662432c8967c669ae57a2ec725385a68e24b7c authored about 5 years ago by Ken Hibino <[email protected]>
Add test for client

634af38e3a70615247b2386c55132c1275d88960 authored about 5 years ago by Ken Hibino <[email protected]>
Add test for processor

d53e5d3350b347dbe987b3ed04edc5dd52480fa3 authored about 5 years ago by Ken Hibino <[email protected]>
Add test for poller

eed375b138d8c07fff3827ef5da8058367bfcf81 authored about 5 years ago by Ken Hibino <[email protected]>
Change shutdown message to use info level logging

facdadd7b0b205f960980181947e30b1d199cf0a authored about 5 years ago by Ken Hibino <[email protected]>
Add test for retry task logic

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