github.com/hibiken/asynq commits | Ecosyste.ms: OpenCollective

Update HistoricalStats method in RDB

5f82b4b365bbd44218ddf6709dc2b208ed2e363a authored over 4 years ago by Ken Hibino <[email protected]>

Update Pause and Unpause methods in RDB

44a3d177f046c500b277b2e1de6a1e0b5244e2da authored over 4 years ago by Ken Hibino <[email protected]>

Add AllQueues method to RDB

d25090c6691a40979e05c7bdda2e3ac5731adbac authored over 4 years ago by Ken Hibino <[email protected]>

Remove stale benchmark test

b5caefd66326a73f4837f3af8fe5a7b653c4f066 authored over 4 years ago by Ken Hibino <[email protected]>

Update WriteServerState and ClearServerState in RDB

becd26479b34c96e491304d049fa30e571c56df3 authored over 4 years ago by Ken Hibino <[email protected]>

Minor fix

4b81b91d3e8e3d5c9a8d513ef0e86c87214a1e4d authored over 4 years ago by Ken Hibino <[email protected]>

Update recoverer

8e23b865e9f288dc5da035d45004b7800743aa57 authored over 4 years ago by Ken Hibino <[email protected]>

Update ListDeadlineExceeded in RDB

a873d488eeb947dafc1f0813ac921964e8da0c55 authored over 4 years ago by Ken Hibino <[email protected]>

Update scheduler to check and enqueue for only the specified queues.

e0a8f1252ad19349d72d38718796692cb26ca04c authored over 4 years ago by Ken Hibino <[email protected]>

Update base package to generate redis keys with hashtag

154113d0d0fccec3637289f7185645d1bfa3a8c9 authored over 4 years ago by Ken Hibino <[email protected]>

Update Enqueue and Schedule commands in rdb

94aa878060dd8caccc99ecf854fdcf4621620770 authored over 4 years ago by Ken Hibino <[email protected]>

Update Kill method in RDB

74f08795f8df2ad1318c5836e8c9a60d3136f5ef authored over 4 years ago by Ken Hibino <[email protected]>

Update CheckAndEnqueue method in RDB

650d7fdbe9568929a687935a4dacf478605f7278 authored over 4 years ago by Ken Hibino <[email protected]>

Update Dequeue command in rdb

565f86ee4f45fc92cafb5182ab2a720b5c9ba7f0 authored over 4 years ago by Ken Hibino <[email protected]>

Move unique key generator function to base

50b6034bf9c78cf5be212dcca89124b6f99d6c6e authored over 4 years ago by Ken Hibino <[email protected]>

Run CI builds using go v1.15.x

669c7995c40e5660fa8510b643ca8af18c0a7cb7 authored over 4 years ago by Ken Hibino <[email protected]>

v0.11.0

6d6a30137988203a5bf136b29caa1c7aaf31d797 authored over 4 years ago by Ken Hibino <[email protected]>

Fix history command

e8fdbc5a724921b14405d4a2c05c0211212e35be authored over 4 years ago by Ken Hibino <[email protected]>

Fix flaky test

6978e93080af86747fc8ffbdebad0db39e77e1dd authored over 4 years ago by Ken Hibino <[email protected]>

Minor comment fix

92d77bbc6e2e1e16c375979ec6872532ff9fdc60 authored over 4 years ago by Ken Hibino <[email protected]>

Add Inspector type

a28f61f313c2654717625e53cc195a72390228a3 authored over 4 years ago by Ken Hibino <[email protected]>

Update changelog

53f9475582ddb55f7c9722f29ec67d0fee75005f authored over 4 years ago by Ken Hibino <[email protected]>

Add healthchecker to check broker connection

a913e6d73f6539dd03b2c9ac9e3c4118d969be9c authored over 4 years ago by Ken Hibino <[email protected]>

Add Pause and Unpause queue methods to Inspector

5f06c308f02343b7a58ee855bf266fe8c79c1131 authored over 4 years ago by Ken Hibino <[email protected]>

v0.10.0

9bd3d8e19ec1c514dd5a50491544516bdf1956de authored over 4 years ago by Ken Hibino <[email protected]>

Use default timeout of 30mins if both timeout and deadline are not

provided

716d3d987eeaf3c0c41b0b0d68e5d43b764864cd authored over 4 years ago by Ken Hibino <[email protected]>

Add version command to CLI

486dcd799b56f22143b46bafa1b143f0cf09402a authored over 4 years ago by Ken Hibino <[email protected]>

Update RDB.Done to remove message from deadlines set

7b9119c70384fe12a34d114b33d81c371e937f77 authored over 4 years ago by Ken Hibino <[email protected]>

Change TaskMessage Timeout and Deadline to int

* This change breaks existing tasks in Redis

0527b934328b6185d2893610a2b34930d6c814da authored over 4 years ago by Ken Hibino <[email protected]>

Add RDB.ListDeadlineExceeded

7657f560ec93d8773ca662d4d0c6b0b0eefcfe0d authored over 4 years ago by Ken Hibino <[email protected]>

Minor code cleanup

199bf4d66acab55b3163c69edb21057769e5b8d3 authored over 4 years ago by Ken Hibino <[email protected]>

Do not start worker goroutine for task already exceeded its deadline

7382e2aeb8ee356c0cd459b84d03ebc3e4f2e314 authored over 4 years ago by Ken Hibino <[email protected]>

Invoke error handler when ctx.Done channel is closed

007fac8055231936d10265e03d758c408f6827cf authored over 4 years ago by Ken Hibino <[email protected]>

Change ErrorHandler function signature

8d43fe407ab47276579bad975e54540043b9e1cd authored over 4 years ago by Ken Hibino <[email protected]>

Return Result struct to caller of Enqueue

34b90ecc8a2bc932df7bb3cb88c95daf059ebc6e authored over 4 years ago by Ken Hibino <[email protected]>

Add migrate command to CLI

The command converts all messages in redis to be compatible for asynq
v0.10.0

195f4603bb4da8e56df84e5f59b713c0364ccd26 authored over 4 years ago by Ken Hibino <[email protected]>

Update docs

2e2c9b9f6b58118c84ea2d212eb05984c5a71141 authored over 4 years ago by Ken Hibino <[email protected]>

Use int64 type for Timeout and Deadline in TaskMessage

7e942ec24133b96b19e1e7a10fc6f470b9d17e73 authored over 4 years ago by Ken Hibino <[email protected]>

Clean up processor test

379da8f7a21a52917883444162dc0979bdf86a75 authored over 4 years ago by Ken Hibino <[email protected]>

Add recoverer

feee87addaca96723bde7bf39b90c828a8953ba3 authored over 4 years ago by Ken Hibino <[email protected]>

Fix processor

7c7de0d8e0bf1ba88c34b2081d41291304c0363b authored over 4 years ago by Ken Hibino <[email protected]>

Add deadline to syncRequest

- syncer will drop a request if its deadline has been exceeded

83f1e20d745c595ceab48cce1d11c66351e46a9f authored over 4 years ago by Ken Hibino <[email protected]>

Update processor to adapt for deadlines set change

- Processor dequeues tasks only when it's available to process
- Processor retries a task when i...

4e8ac151aea7fb71aa9e756547c4f34c43b94099 authored over 4 years ago by Ken Hibino <[email protected]>

Update RDB.Requeue to remove message from deadlines set

08b71672aa822ea22d5912e2a97d0f0e32dbc5bf authored over 4 years ago by Ken Hibino <[email protected]>

Update RDB.Dequeue to return deadline as time.Time

92af00f9fd62badf1f02b560e0e24e5dc8ce9b59 authored over 4 years ago by Ken Hibino <[email protected]>

Update RDB.Kill to remove message from deadlines set

113451ce6a1024c6a998f551817df3e2a219ebde authored over 4 years ago by Ken Hibino <[email protected]>

Update RDB.Retry to remove message from deadlines set

9cd9f3d6b44e7a342acb9d1384c45f31db0ac264 authored over 4 years ago by Ken Hibino <[email protected]>

Update RDB.Dequeue to return message and deadline

9b05dea3941744b9f77e10b6b94f37ee3483c2e2 authored over 4 years ago by Ken Hibino <[email protected]>

Add task message to deadlines set on dequeue

Updated dequeueCmd to decode the message and compute its deadline and add
the message to the Dea...

6cc5bafabaafbd444eea704f39519d4efa11ba12 authored over 4 years ago by Ken Hibino <[email protected]>

Add redis key for deadlines in base package

5dddc35d7cb47527dad66ed14fe52bd8042adcf1 authored over 4 years ago by Ken Hibino <[email protected]>

Replace github.com/rs/xid with github.com/google/uuid

8b60e6a2687633cb995338cd1af760cb5bce3ae8 authored over 4 years ago by Ken Hibino <[email protected]>

Fix Client.Enqueue to always call enqueue

Closes https://github.com/hibiken/asynq/issues/158

4e5f5969108de59ffd2574471cd2e3399a2f4914 authored over 4 years ago by Ken Hibino <[email protected]>

v0.9.4

8bf5917cd918452541dbb7d61252b3e44d9bd66b authored over 4 years ago by Ken Hibino <[email protected]>

Fix requeue logic in processor

7f30fa2bb6819b9aef47cf77f6a0cd73e3338d5d authored over 4 years ago by Ken Hibino <[email protected]>

v0.9.3

ade6e61f510f95ebb9d8bf199938b84cc8800132 authored over 4 years ago by Ken Hibino <[email protected]>

Fix JSON number ovewflow issue

a2abeedaa0c521a01f378c016e5bb4cb73a7f0ec authored over 4 years ago by Ken Hibino <[email protected]>

processor: log detail err in markAsDone func

81bb52b08ca8fec45e1389f63cd32b98416e5c75 authored over 4 years ago by lion.zhao <[email protected]>

v0.9.2

bc2a7635a0a9391a6e95c24dc850d3abd4643c77 authored over 4 years ago by Ken Hibino <[email protected]>

Update docs for pause feature

f65d408bf9bae8defb71b328212ad4b8ab378e2e authored over 4 years ago by Ken Hibino <[email protected]>

Limit the number of tasks moved by CheckAndEnqueue to prevent a long

running script

06c4a1c7f86d739eb084ee94bf70cbafea27a45b authored over 4 years ago by Ken Hibino <[email protected]>

Add benchmark test to verify client enqueue performance while server is

running

4749b4bbfc1ff4bd9c81b0462bbeb491b7c84dea authored over 4 years ago by Ken Hibino <[email protected]>

Update Dequeue operation to skip paused queues

363cfedb49110b14733e4af9dab59493e206dfb7 authored over 4 years ago by Ken Hibino <[email protected]>

Add pause and unpause command to CLI

d6a5c84dc6cfe6c09cf9a90b7258a8211d28d2f3 authored over 4 years ago by Ken Hibino <[email protected]>

Update stats command to show queue paused status

4e800a7f6818dfbcd9be174b15f28e08deec4333 authored over 4 years ago by Ken Hibino <[email protected]>

Add Pause and Unpause methods to rdb

4595bd41c3bb7deab60d425f2d1bde6caaa621c9 authored over 4 years ago by Ken Hibino <[email protected]>

Fix data race in test

8af4cbad51ffc3db8eea5619794027bb4c4c9130 authored over 4 years ago by Ken Hibino <[email protected]>

Fix cli build

e236d55477c4d4fe38c15a7687829c203ce093fb authored over 4 years ago by Ken Hibino <[email protected]>

Refactor server state management

a38f628f3b24090a63bececc44d87e11d9edbb75 authored over 4 years ago by Ken Hibino <[email protected]>

v0.9.1

69ad583278a40c3d7d8eda583316e8271dc98511 authored over 4 years ago by Ken Hibino <[email protected]>

Add helper functions to extract task metadata from context

23f46dde529af27bfcc484cacaf7234d14fb6405 authored over 4 years ago by Ken Hibino <[email protected]>

remove typo and redundant code

39188fe9301217d5f52d13bac70756b001c9a530 authored over 4 years ago by lihe <[email protected]>

Change internal constructor signatures.

Created "params" type to avoid positional arguments.
Personally it feels more explicit and reads...

4492ed9255ff3576bb8b1974b0b506645cca022b authored over 4 years ago by Ken Hibino <[email protected]>

Update readme

4e3e0539894732e01d168a3b298ae11f5cbfd99c authored over 4 years ago by Ken Hibino <[email protected]>

v0.9.0

aef0775c05e24101c0a8a1b3c68de0b3bb31fe2d authored over 4 years ago by Ken Hibino <[email protected]>

Add log messages around Server.Quiet

de146993d2db0d826f988d3cb4b5f8864222c9b9 authored over 4 years ago by Ken Hibino <[email protected]>

Allow setting minimum log level for logger

d13f7e900f3138a5746f05b43ce2ca32ff379d92 authored over 4 years ago by Ken Hibino <[email protected]>

Change default log level to info

cfcd19a2228c8b845d0cb0fce5bda341f941b26f authored over 4 years ago by Ken Hibino <[email protected]>

Minor code cleanup

60cbf8dc5a70d7d0ba3dcde3847cdc5f2ee39f0a authored over 4 years ago by Ken Hibino <[email protected]>

Clean up log messages

Moved development purpose log messages to DEBUG level.

fb38086590079ced61ac87bf2e5a4fdeefa0aeca authored over 4 years ago by Ken Hibino <[email protected]>

Define test flags for package testing

Added test flags for

- redis address (defaults to "localhost:6379")
- redis db number (defaults...

24ee4b9693020196ddc28f901f01679f6cf4d462 authored over 4 years ago by Ken Hibino <[email protected]>

Update changelog

7849b395bd56186b595ce7afc62dd7639a7f612c authored over 4 years ago by Ken Hibino <[email protected]>

Change LogLevel to satisfy flag.Value interface

fa3082e5bba0450122cc1042867d3979a3e8061f authored over 4 years ago by Ken Hibino <[email protected]>

Simplify Logger interface

b63476ddc867c1adac7c42f66052791f178d3a61 authored over 4 years ago by Ken Hibino <[email protected]>

Add log messages around Server.Quiet

210b026b013e38535ed8ca7f4753f82e2c88b6e5 authored over 4 years ago by Ken Hibino <[email protected]>

Minor code cleanup

556b2103fe240defd99bd949caedbb85f8c9fd04 authored over 4 years ago by Ken Hibino <[email protected]>

Clean up log messages

Moved development purpose log messages to DEBUG level.

0289bc7a106d7cbaa19143434b38a65c3321fad1 authored over 4 years ago by Ken Hibino <[email protected]>

Change default log level to info

ae942c93e5fd6a26b64d04f6294bbe8ddea84eb5 authored over 4 years ago by Ken Hibino <[email protected]>

Define test flags for package testing

Added test flags for

- redis address (defaults to "localhost:6379")
- redis db number (defaults...

0faf97f146d413073540bc3cbdda4c82a3a41d0a authored over 4 years ago by Ken Hibino <[email protected]>

Allow setting minimum log level for logger

00b82904c600dbdeb7d0ed0b1461b8b4c873b0b6 authored over 4 years ago by Ken Hibino <[email protected]>

Change LogLevel to satisfy flag.Value interface

73d62844e60073678129a09180b5092087dde884 authored over 4 years ago by Ken Hibino <[email protected]>

Simplify Logger interface

a866369866878f0c7794fabec3b28293ffeaafbb authored over 4 years ago by Ken Hibino <[email protected]>

Update changelog

711bfa371ff61ca3af0008c57d6f8733ce379afa authored over 4 years ago by Ken Hibino <[email protected]>

v0.8.3

26b78136badb57f4512faf0c96bc6e7e8ef4569e authored over 4 years ago by Ken Hibino <[email protected]>

Add redis conn close func to client

44aad7f0379af3276206e0a1b350595e4ab8be55 authored over 4 years ago by t-asaka <[email protected]>

v0.8.2

9884d5f2fa2b062082615352298a603992f3da6a authored over 4 years ago by Ken Hibino <[email protected]>

Update docs

826f1ecff43c22fda325a672dac39441e11d53ca authored over 4 years ago by Ken Hibino <[email protected]>

Make sure to invoke CancelFunc in all cases

24f2b64c6ce427e133ad54a45c78b8b4f049c830 authored over 4 years ago by Ken Hibino <[email protected]>

Add tests to simulate cases where server cannot talk to redis

1c1474c55c4e588ee2b260860136f0fedcb03182 authored over 4 years ago by Ken Hibino <[email protected]>

Clean up tests

5161b9368ae81da57b97b8000426e33b8345a9a4 authored over 4 years ago by Ken Hibino <[email protected]>

Add test for signal handling

0c998a8e17a5dccec9385084777f57319248d6aa authored over 4 years ago by Ken Hibino <[email protected]>