shiblon/entroq

Allow claims to pull from any of multiple queues, instead of just a single queue

Closed this issue · 2 comments

The gRPC wire protocol would probably not need to change here, the claim query queue field would simply become repeated, leaving the tag number in place.

Draft proposal:

  • ClaimAny and TryClaimAny added
  • Switch Claim and TryClaim to be implemented in terms of those
  • Postgres query would add elements to the WHERE clause for claims
  • In-memory would need some as-yet-unspecified changes

Additionally, the worker code, which currently has a hacky approach to allowing workers to pull from multiple queues, would be reimplemented to use this base functionality instead.

Completed in commit 63c80cc