mirror of
https://github.com/hibiken/asynq.git
synced 2026-04-26 15:35:55 +03:00
[PR #48] [MERGED] Update asynqmon CLI to handle multiple queues #567
Labels
No labels
CLI
bug
designing
documentation
duplicate
enhancement
good first issue
good first issue
help wanted
idea
invalid
investigate
needs-more-info
performance
pr-welcome
pull-request
question
wontfix
work in progress
work in progress
work-around-available
No milestone
No project
No assignees
1 participant
Notifications
Due date
No due date set.
Dependencies
No dependencies set.
Reference
starred/asynq#567
Loading…
Add table
Add a link
Reference in a new issue
No description provided.
Delete branch "%!s()"
Deleting a branch is permanent. Although the deleted branch may continue to exist for a short time before it actually gets removed, it CANNOT be undone in most cases. Continue?
📋 Pull Request Information
Original PR: https://github.com/hibiken/asynq/pull/48
Author: @hibiken
Created: 1/10/2020
Status: ✅ Merged
Merged: 1/11/2020
Merged by: @hibiken
Base:
master← Head:feature/asynqmon-multiq📝 Commits (9)
f5cf6a7Update RDB.Enqueue* methods to be multi queue awared5970d9Remove stale field in processor struct5d431bcMaintain a set of queue names in redis set70f1320Change RDB.CurrentStats to be multi-queue aware8735718Include each queue counts in stats command outputf1e5768Update RDB.ListEnqueued to list tasks from all queuesf96aee3Add "Queue" column to the output ofasynqmon lsd4c7003Allow filtering results ofasynqmon ls enqueuedby providing queueaede018Fix flaky tests📊 Changes
13 files changed (+666 additions, -286 deletions)
View changed files
📝
CHANGELOG.md(+2 -0)📝
client_test.go(+1 -1)📝
internal/asynqtest/asynqtest.go(+16 -3)📝
internal/base/base.go(+3 -1)📝
internal/rdb/inspect.go(+124 -28)📝
internal/rdb/inspect_test.go(+390 -180)📝
internal/rdb/rdb.go(+7 -2)📝
internal/rdb/rdb_test.go(+38 -28)📝
processor.go(+0 -6)📝
processor_test.go(+6 -6)📝
scheduler_test.go(+6 -6)📝
tools/asynqmon/cmd/ls.go(+39 -23)📝
tools/asynqmon/cmd/stats.go(+34 -2)📄 Description
No description provided
🔄 This issue represents a GitHub Pull Request. It cannot be merged through Gitea due to API limitations.