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 upper case characters in queue name

46b23d6495552be9ea16971216ea84ff8d015983 authored over 3 years ago by Ken Hibino <[email protected]>
v0.18.1

c0ae62499f8a9f4ba34ca02ed5f5ba08cf6f427c authored over 3 years ago by Ken Hibino <[email protected]>
Fix recoverer to run task recovering logic every minute

ff6768f9bb44c92ad8f7c523fb80a98d24f0571e authored over 3 years ago by Ken Hibino <[email protected]>
Update changelog

7744ade3629d8814597e98cd321e2b9b04012631 authored over 3 years ago by Ken Hibino <[email protected]>
Update recoverer to recover tasks on server startup

f532c953948a886d24ab48d1d3c77d57009b92fa authored over 3 years ago by Ken Hibino <[email protected]>
Update readme

d5e9f3b1bd6ec64b5bf8ed55b0310d95a13bbe54 authored over 3 years ago by Ken Hibino <[email protected]>
v0.18.0

d02b722d8a5faa290cac4f32669ef14f06895923 authored over 3 years ago by Ken Hibino <[email protected]>
Rename Inspector.CurrentStats to GetQueueInfo

b358de907ea15bdda6a61a963b1eb35f4f09edd7 authored over 3 years ago by Ken Hibino <[email protected]>
Rename Inspector.CancelActiveTask to CancelProcessing

8ee1825e679342e3cdc162a1a5ea8c0603e5a02d authored over 3 years ago by Ken Hibino <[email protected]>
Make NodeCluster fields read-only

c8bda26bed419abd668d2d8ec6c277051ffe00c7 authored over 3 years ago by Ken Hibino <[email protected]>
Update WorkerInfo and remove unnecessary types

96c51fdc23b75c0239356b6e11366484ffeebc21 authored over 3 years ago by Ken Hibino <[email protected]>
Update Inspector.List*Task methods to return ErrQueueNotFound

ea9086fd8be24a77ff163ae7b2b078f92d78bbd3 authored over 3 years ago by Ken Hibino <[email protected]>
Update Inspector.ListArchivedTasks

e63d51da0c33c44a4fe7f0e8659f42b7156126d4 authored over 3 years ago by Ken Hibino <[email protected]>
Record last_failed_at time on Retry or Archive event

87264b66f3c1219c578e9855b06159e87eba5b58 authored over 3 years ago by Ken Hibino <[email protected]>
Update List methods (expect for ListArchived)

840f7245b1fa3f30f8e9c1baceba6881eb197731 authored over 3 years ago by Ken Hibino <[email protected]>
Replace ArchiveTaskByKey with ArchiveTask in Inspector

0ec3b55e6b25462da3ddcccd880a5e57eef3b340 authored over 3 years ago by Ken Hibino <[email protected]>
Replace DeleteTaskByKey with DeleteTask in Inspector

4bcc5ab6aa729489dc902ef35a4723cca989338e authored over 3 years ago by Ken Hibino <[email protected]>
Update Client.Enqueue to return TaskInfo

b835090ad8b0cc3fbe8fd3933dcfcac1b5030dfd authored over 3 years ago by Ken Hibino <[email protected]>
Define TaskInfo type

09cbea66f6d0f6f449b87c36984b240b5956a904 authored over 3 years ago by Ken Hibino <[email protected]>
Refactor redis keys and store messages in protobuf

Changes:
- Task messages are stored under "asynq:{<qname>}:t:<task_id>" key in redis, value is a...

b9c2572203dbb8252c2a6724b539546f55e3df4b authored over 3 years ago by Ken Hibino <[email protected]>
Change TaskInfo to use public fields instead of methods

a9feec5967d715f95d44f5624aaf2a306a0034d1 authored over 3 years ago by Ken Hibino <[email protected]>
Fix build

1812d05d21cb45c3f110faf16080fce5a829059c authored over 3 years ago by Ken Hibino <[email protected]>
Update RDB.EnqueueUnique and RDB.ScheduleUnique with specific errors

d98ecdebb404be0fd34d762168ca89a106c2cd32 authored over 3 years ago by Ken Hibino <[email protected]>
Add migration command in CLI

99c7ebeef260ed156af09ad3a8b3bc76ef882830 authored over 3 years ago by Ken Hibino <[email protected]>
Update RDB.Dequeue with new errors package

a19ad1938277dee6c7f2f5d11edbee59ee0e6cb3 authored over 3 years ago by Ken Hibino <[email protected]>
Add errors.RedisCommandError type

ffe9aa74b36ef7d6e7972d9098b9611a45417148 authored over 3 years ago by Ken Hibino <[email protected]>
Update RDB.CurrentStats and RDB.HistoricalStats with specific errors

d2d4029aba5b80a60c20657485c0dfba142ed806 authored over 3 years ago by Ken Hibino <[email protected]>
Change Server API

* Rename ServerStatus to ServerState internally

* Rename terminate to shutdown internally

...

9c95c416518af5252c5b8713de365c9305bfe181 authored over 3 years ago by Ken Hibino <[email protected]>
Update RDB.RemoveQueue with specific error types

76bd865ebcd02b349d4487cfcea7769d40ed5fd8 authored over 3 years ago by Ken Hibino <[email protected]>
Update rdb.List* methods with specific errors

136d1c9ea93b23563a196499bf2b6241df0f37b9 authored over 3 years ago by Ken Hibino <[email protected]>
Return QueueNotFoundError from DeleteAll* methods

52e04355d3090b36b4507942e5f9c0bee9b23b54 authored over 3 years ago by Ken Hibino <[email protected]>
Update RDB.RunAll* methods with task state

cde3e57c6ccfb2e2b104c03575f3658e773fc141 authored over 3 years ago by Ken Hibino <[email protected]>
Return QueueNotFoundError from ArchiveAll* methods

dd66acef1b7acc8efded9cb08fb2b2d28849da7c authored over 3 years ago by Ken Hibino <[email protected]>
Update RDB methods with new errors package

4af65d5fa5e10f5afc86bd5efa6f4852a05ad8e6 authored over 3 years ago by Ken Hibino <[email protected]>
Update tests for RDB.DeleteTask and RDB.ArchiveTask

30a3d9641a68d4ba07bec5f8889bb16d88af3100 authored over 3 years ago by Ken Hibino <[email protected]>
Update RDB.RunTask with more specific errors

961582cba6195da2fbd8b429a2b8b9fbcfcd07e5 authored over 3 years ago by Ken Hibino <[email protected]>
Update RDB.Requeue with task state

5d7f1b6a8000f63e5744446c9139dbfe179d837c authored over 3 years ago by Ken Hibino <[email protected]>
Minor fixes

8117ce89720529865e75365ac3ea093a7e62f6bc authored over 3 years ago by Ken Hibino <[email protected]>
Update RDB.DeleteTask with task state

430dbb298e359084057197eab3294062639e1be9 authored over 3 years ago by Ken Hibino <[email protected]>
Update RDB.ArchiveAll methods with task state

675826be5fd03e089467802218d65859479cf24c authored over 3 years ago by Ken Hibino <[email protected]>
Update RDB.ArchiveAllPendingTasks with task state

62f4e46b730395e671d1031ca72ab7fbc28e0a58 authored over 3 years ago by Ken Hibino <[email protected]>
Reorganize test for RDB.ArchiveTask

a500f8a53456491e6f8fef3ecb13ea155fef9ca6 authored over 3 years ago by Ken Hibino <[email protected]>
Update errors package with detailed comments

bcfeff38ed691fe01943d6802f575c8a3db65d03 authored over 3 years ago by Ken Hibino <[email protected]>
Update RDB.ArchiveTask with custom errors

12a90f6a8dc93d2896a3b0794472ebcb7a530598 authored over 3 years ago by Ken Hibino <[email protected]>
Create internal errors package

807624e7dda40eda5d99228740c8435025a57a5b authored over 3 years ago by Ken Hibino <[email protected]>
Add LastFailedAt to TaskInfo

cd351d49b9ae8dd318a4bd47aece8c683287f1a3 authored over 3 years ago by Ken Hibino <[email protected]>
Update rdb.ArchiveTask with more specific error types

4d65024bd7c8c5c066fb8e6064b786dbcc828e9a authored over 3 years ago by Ken Hibino <[email protected]>
Rename error types

76486b5cb46f7a99807456128bd155ce305ed6d8 authored over 3 years ago by Ken Hibino <[email protected]>
Add a list of canonical errors in base package

1db516c53c0f404935a7eed35daddcab9620a8a2 authored over 3 years ago by Ken Hibino <[email protected]>
Misc cleanup

8aeeb61c9deeb5e18e5f9515f78d599ca45aa976 authored over 3 years ago by Ken Hibino <[email protected]>
Update RDB.ArchiveTask with task state

cb5bdf245cb276188d471a6ada2fe4d734e788b5 authored over 3 years ago by Ken Hibino <[email protected]>
Update RDB.RunTask with task state

267493ccefe02abcacd369c459fe9850f5f49416 authored over 3 years ago by Ken Hibino <[email protected]>
Update RDB.Dequeue with task state

f2284be43d53405f70ebd92a7351f5c8a4264ef6 authored over 3 years ago by Ken Hibino <[email protected]>
Define RDB.GetTaskInfo

8922d2423ab6bdf6af804068bdd6084a0a9f0901 authored over 3 years ago by Ken Hibino <[email protected]>
Update RDB.ForwardIfReady with task state

3cadab55cb0d283413df264d64ae990144f65f4c authored over 3 years ago by Ken Hibino <[email protected]>
Update RDB.ScheduleUnique with task state

298a420f9fb69a25290e01292e03e9a4a16fa998 authored over 3 years ago by Ken Hibino <[email protected]>
Update RDB.Schedule with task state

b1d717c842ba3c5f6a7ccd505f632416e982929b authored over 3 years ago by Ken Hibino <[email protected]>
Update RDB.EnqueueUnique with task state

56e5762eea158f390dea0d95b822da6808a5565f authored over 3 years ago by Ken Hibino <[email protected]>
Update RDB.Enqueue with task state

5ec41e388bc1c6e62a66ac152681f498ae8d135c authored over 3 years ago by Ken Hibino <[email protected]>
Change payload to byte slice

476812475ef148798a72b6f1c861e730845c1962 authored over 3 years ago by Ken Hibino <[email protected]>
Move inspeq package content to asynq package

12f4c7cf6efc5ae55d707b83f23828b59b620345 authored over 3 years ago by Ken Hibino <[email protected]>
Refactor redis keys and store messages in protobuf

Changes:
- Task messages are stored under "asynq:{<qname>}:t:<task_id>" key in redis, value is a...

7af3981929d1289fb2ce189db817a46b09177292 authored over 3 years ago by Ken Hibino <[email protected]>
Update example code in README

bf546211963373722c67994c9f21d10992fe713b authored over 3 years ago by Ken Hibino <[email protected]>
Fix error in readme

27baf6de0d5acded5df964919237649407cac266 authored over 3 years ago by Ken Hibino <[email protected]>
Fix CLI build

1bd0bee1e5b85705a00886c5b0fcf07829f711bf authored over 3 years ago by Ken Hibino <[email protected]>
Update RDB.Retry, RDB.Archive with task state

77ded502ab49d1f0e722335fa7837bdf0218151d authored over 3 years ago by Ken Hibino <[email protected]>
Fix lua scripts for redis cluster

68839dc9d361ee805299a53bada7a48b92a65c00 authored over 3 years ago by Ken Hibino <[email protected]>
Fix lua script for redis-cluster mode

e01c6379c8c26c2d115fd94583121f9342491fd6 authored over 3 years ago by Ken Hibino <[email protected]>
Add Inspector.GetTaskInfo

4765742e8aa92ef057606eb6072874cafff266d8 authored over 3 years ago by Ken Hibino <[email protected]>
Add TaskState type to base package

0bf767cf2106cba7db2b8ffd8e61a51b7c2c1665 authored over 3 years ago by Ken Hibino <[email protected]>
Use md5 to generate checksum for unique key

a0df047f712833424ec6b6f02aa0505e19fe312c authored over 3 years ago by Ken Hibino <[email protected]>
(fix): Clear unique lock when task is deleted via Inspector

68dd6d9a9d156f819ec4a4703c8d5a966811b499 authored over 3 years ago by Ken Hibino <[email protected]>
Fix recoverer test

6cce31a134bc951c3ff8a4a425f34a1233712d27 authored over 3 years ago by Ken Hibino <[email protected]>
Replace RunTaskByKey with RunTask in Inspector

456edb6b71862386019420a6c7a93646ac8101d5 authored over 3 years ago by Ken Hibino <[email protected]>
Update ProcessorRetry test

f9d7af3def37a997a415bf470d17dfe528d4d41a authored over 3 years ago by Ken Hibino <[email protected]>
Format payload bytes in CLI output

b0321fb4659a414dd2becd8d3ac702ccc525796d authored over 3 years ago by Ken Hibino <[email protected]>
Rename cli subcommand to not to use dash

7776c7ae538ad19110a0c596e26f3b7ed5cbf69a authored over 3 years ago by Ken Hibino <[email protected]>
Add LastFailedAt field to TaskMessage

62168b8d0d65263a293ddd627c057d371957a849 authored over 3 years ago by Ken Hibino <[email protected]>
Add task inspect command

709ca79a2b182e1797b964280e4933ea71839d6c authored over 3 years ago by Ken Hibino <[email protected]>
Add String method to TaskState

08d8f0b37c8282a5a3218d465b023a0d6e7500f4 authored over 3 years ago by Ken Hibino <[email protected]>
Minor fix in queue command

385323b6794cc4652e7b2d01f3913662019979d1 authored over 3 years ago by Ken Hibino <[email protected]>
Fix asynq CLI build

77604af265f0907b286f98f9426b068012b1b432 authored over 3 years ago by Ken Hibino <[email protected]>
v0.17.2

2516c4babac835a04b59822eebb9a0016351e177 authored over 3 years ago by Ken Hibino <[email protected]>
Free uniqueness lock when task is deleted

ebe482a65ca521d3de8c62c61687f8fd3ec47e56 authored over 3 years ago by Ken Hibino <[email protected]>
Update README

3e9fc2f9723d55629652f1a9b87bc5b8210411b1 authored over 3 years ago by Vic Shóstak <[email protected]>
Update README with a new logo

63ce9ed0f925912bd95c8464d1ee9dfae4ddf109 authored over 3 years ago by Vic Shóstak <[email protected]>
v0.17.1

32d3f329b9feea01f1a604a9e882e3cbfcd5c2c3 authored almost 4 years ago by Ken Hibino <[email protected]>
Fix bug in RDB.memoryUsage

544c301a8b2db02bf311e3588495fbc30ef5df38 authored almost 4 years ago by Ken Hibino <[email protected]>
v0.17.0

8b997d2fab2280c37f027caadf729c425dd39957 authored almost 4 years ago by Ken Hibino <[email protected]>
Add dial, read, write timeout options to RedisConnOpt

901105a8d7c3b38a28e453a95921636c96ccad6d authored almost 4 years ago by Ken Hibino <[email protected]>
v0.16.1

aaa3f1d4fd2a93d6e8348a1897988afe5e6ea6c0 authored almost 4 years ago by Ken Hibino <[email protected]>
Replaced blocking `KEYS XXX:*` command to non-blocking `SCAN XXX:*`

More details: https://redis.io/commands/KEYS

4722ca2d3de13622a4210e64354b92fec191762f authored almost 4 years ago by disc <[email protected]>
v0.16.0

6a9d9fd71706a6424a5e11c0294524b0707e1df1 authored almost 4 years ago by Ken Hibino <[email protected]>
Add Unregister method to Scheduler

de28c1ea19e192f1f51e108953fc4256a5c51722 authored almost 4 years ago by Ken Hibino <[email protected]>
Add benchmark tests for rdb package

f618f5b1f553d5e07b0e88916910a6d40e388111 authored almost 4 years ago by Ken Hibino <[email protected]>
Minor fix

aa936466b34294f9464a4beb872266b8636e1818 authored almost 4 years ago by Ken Hibino <[email protected]>
Run CI build with go1.16

5d1ec70544d75de5a6f4ed0b111de3735c62498e authored almost 4 years ago by Ken Hibino <[email protected]>
Add Web UI section in README

d1d3be9b005499af2f92e7fb4259078d7fc719a4 authored almost 4 years ago by Ken Hibino <[email protected]>
v0.15.0

bc77f6fe143340a8803c4d101d9a443d8f006f3e authored almost 4 years ago by Ken Hibino <[email protected]>
Move all inspector related code to subpackage inspeq

e13122723aa7bbc5db46676a872e7a2652dca6de authored almost 4 years ago by Ken Hibino <[email protected]>