[PR #190] [MERGED] Support Redis Cluster #1670

Closed
opened 2026-03-07 22:11:50 +03:00 by kerem · 0 comments
Owner

📋 Pull Request Information

Original PR: https://github.com/hibiken/asynq/pull/190
Author: @hibiken
Created: 9/10/2020
Status: Merged
Merged: 9/12/2020
Merged by: @hibiken

Base: masterHead: feature/redis-cluster


📝 Commits (10+)

  • 03ea601 Update base package to generate redis keys with hashtag
  • 8712499 Move unique key generator function to base
  • faeeb2c Update Enqueue and Schedule commands in rdb
  • 62149e5 Update Dequeue command in rdb
  • f085296 Update Done method in RDB
  • 0e6d153 Update Retry method in RDB
  • 0ca14cb Update Kill method in RDB
  • 3795c42 Update Requeue method in RDB
  • 6515d45 Update CheckAndEnqueue method in RDB
  • 281b80f Update scheduler to check and enqueue for only the specified queues.

📊 Changes

61 files changed (+6821 additions, -4678 deletions)

View changed files

📝 CHANGELOG.md (+57 -0)
📝 CONTRIBUTING.md (+1 -0)
📝 README.md (+25 -30)
📝 asynq.go (+60 -4)
📝 asynq_test.go (+38 -5)
📝 benchmark_test.go (+10 -18)
📝 client.go (+73 -84)
📝 client_test.go (+243 -238)
📝 context.go (+13 -0)
📝 context_test.go (+14 -2)
📝 doc.go (+13 -11)
docs/assets/cluster.png (+0 -0)
📝 docs/assets/demo.gif (+0 -0)
📝 go.mod (+1 -1)
📝 go.sum (+2 -0)
📝 healthcheck_test.go (+2 -0)
📝 heartbeat_test.go (+4 -2)
📝 inspector.go (+238 -132)
📝 inspector_test.go (+1066 -775)
📝 internal/asynqtest/asynqtest.go (+128 -84)

...and 41 more files

📄 Description

Closes #138
Closes #182

Design Doc


🔄 This issue represents a GitHub Pull Request. It cannot be merged through Gitea due to API limitations.

## 📋 Pull Request Information **Original PR:** https://github.com/hibiken/asynq/pull/190 **Author:** [@hibiken](https://github.com/hibiken) **Created:** 9/10/2020 **Status:** ✅ Merged **Merged:** 9/12/2020 **Merged by:** [@hibiken](https://github.com/hibiken) **Base:** `master` ← **Head:** `feature/redis-cluster` --- ### 📝 Commits (10+) - [`03ea601`](https://github.com/hibiken/asynq/commit/03ea601c05e87d571655284e1b9bb26235a9eb02) Update base package to generate redis keys with hashtag - [`8712499`](https://github.com/hibiken/asynq/commit/87124993f892a22a136cb0377306ce9e6ba3915a) Move unique key generator function to base - [`faeeb2c`](https://github.com/hibiken/asynq/commit/faeeb2c82087a77372db3759b7fcff77bdbbeaac) Update Enqueue and Schedule commands in rdb - [`62149e5`](https://github.com/hibiken/asynq/commit/62149e5a0899073752f113b68d59eba7e673f8d6) Update Dequeue command in rdb - [`f085296`](https://github.com/hibiken/asynq/commit/f085296d705759ebc8346945177e1a3e250ef1c0) Update Done method in RDB - [`0e6d153`](https://github.com/hibiken/asynq/commit/0e6d153572d07fc36dfc1017eedc331181694b99) Update Retry method in RDB - [`0ca14cb`](https://github.com/hibiken/asynq/commit/0ca14cb586dd28818776c51c7f1b88289241b094) Update Kill method in RDB - [`3795c42`](https://github.com/hibiken/asynq/commit/3795c42c9881b7284084656f52bbdc379058f66b) Update Requeue method in RDB - [`6515d45`](https://github.com/hibiken/asynq/commit/6515d4522bdf391c6b9725a33f2898aaeceda479) Update CheckAndEnqueue method in RDB - [`281b80f`](https://github.com/hibiken/asynq/commit/281b80f4bb31396046a6579e3ec8357995b9d6de) Update scheduler to check and enqueue for only the specified queues. ### 📊 Changes **61 files changed** (+6821 additions, -4678 deletions) <details> <summary>View changed files</summary> 📝 `CHANGELOG.md` (+57 -0) 📝 `CONTRIBUTING.md` (+1 -0) 📝 `README.md` (+25 -30) 📝 `asynq.go` (+60 -4) 📝 `asynq_test.go` (+38 -5) 📝 `benchmark_test.go` (+10 -18) 📝 `client.go` (+73 -84) 📝 `client_test.go` (+243 -238) 📝 `context.go` (+13 -0) 📝 `context_test.go` (+14 -2) 📝 `doc.go` (+13 -11) ➕ `docs/assets/cluster.png` (+0 -0) 📝 `docs/assets/demo.gif` (+0 -0) 📝 `go.mod` (+1 -1) 📝 `go.sum` (+2 -0) 📝 `healthcheck_test.go` (+2 -0) 📝 `heartbeat_test.go` (+4 -2) 📝 `inspector.go` (+238 -132) 📝 `inspector_test.go` (+1066 -775) 📝 `internal/asynqtest/asynqtest.go` (+128 -84) _...and 41 more files_ </details> ### 📄 Description Closes #138 Closes #182 [Design Doc](https://docs.google.com/document/d/1DF8O8cnmp1-UiUBCFB64-89ZhcjjcLzHpo0dJEotBzk/) --- <sub>🔄 This issue represents a GitHub Pull Request. It cannot be merged through Gitea due to API limitations.</sub>
kerem 2026-03-07 22:11:50 +03:00
Sign in to join this conversation.
No milestone
No project
No assignees
1 participant
Notifications
Due date
The due date is invalid or out of range. Please use the format "yyyy-mm-dd".

No due date set.

Dependencies

No dependencies set.

Reference
starred/asynq#1670
No description provided.