asynq
asynq copied to clipboard
hibiken
Simple, reliable, and efficient distributed task queue in Go
I have another question on graceful shutdown that I think is related to this; The server has a Stop() and a Shutdown(), from reading the comments Stop() prevents the server...
I want to run `asynq.Server`-s on top of pool of machines (vm-s, containers whatever). Each machine runs single server with `Concurrency = 1`. Once a task is successfully executed, I...
benchstat keeps failing on all CI runs.
https://github.com/hibiken/asynq/blob/6a7bf2ceff1e920b3e8542635b273c4dcca192ac/internal/rdb/rdb.go#L1448-L1457
**Is your feature request related to a problem? Please describe.** Would be great if we could configure different queue backends like SQS, GCP Pub/Sub etc... **Describe the solution you'd like**...
If I read the code correctly, I think the error assignment in line 427 as well as line 429 are ineffectual as the `err` is later reassigned at line 431....
Is there a way to get the throughput of messages as they are being dequeued by consumers?
**Describe the bug** For testing purposes, I have a task obj that stores a reference to the `asynq.Client` object (I have tested w/ both pointer and non-pointer). When the task...
**Is your feature request related to a problem? Please describe.** We want to use asynq to stream some messages, once the server publishes the message in the channel, the client...
Bumps [github.com/hibiken/asynq](https://github.com/hibiken/asynq) from 0.21.0 to 0.24.1. Release notes Sourced from github.com/hibiken/asynq's releases. v0.24.1 Changed Updated package version dependency for go-redis v0.24.0 Added PreEnqueueFunc, PostEnqueueFunc is added in Scheduler and deprecated...
![dependabot[bot] avatar](https://avatars.githubusercontent.com/in/29110?v=4 "dependabot[bot] avatar"){kind=avatar}