mirror of
https://github.com/hibiken/asynq.git
synced 2024-12-26 07:42:17 +08:00
(cli): Add group ls command
This commit is contained in:
parent
39718f8bea
commit
2c783566f3
48
tools/asynq/cmd/group.go
Normal file
48
tools/asynq/cmd/group.go
Normal file
@ -0,0 +1,48 @@
|
||||
// Copyright 2022 Kentaro Hibino. All rights reserved.
|
||||
// Use of this source code is governed by a MIT license
|
||||
// that can be found in the LICENSE file.
|
||||
|
||||
package cmd
|
||||
|
||||
import (
|
||||
"fmt"
|
||||
"os"
|
||||
|
||||
"github.com/spf13/cobra"
|
||||
)
|
||||
|
||||
func init() {
|
||||
rootCmd.AddCommand(groupCmd)
|
||||
groupCmd.AddCommand(groupListCmd)
|
||||
groupListCmd.Flags().StringP("queue", "q", "", "queue to inspect")
|
||||
groupListCmd.MarkFlagRequired("queue")
|
||||
}
|
||||
|
||||
var groupCmd = &cobra.Command{
|
||||
Use: "group",
|
||||
Short: "Manage groups",
|
||||
}
|
||||
|
||||
var groupListCmd = &cobra.Command{
|
||||
Use: "ls",
|
||||
Short: "List groups",
|
||||
Args: cobra.NoArgs,
|
||||
Run: groupLists,
|
||||
}
|
||||
|
||||
func groupLists(cmd *cobra.Command, args []string) {
|
||||
qname, err := cmd.Flags().GetString("queue")
|
||||
if err != nil {
|
||||
fmt.Println(err)
|
||||
os.Exit(1)
|
||||
}
|
||||
inspector := createInspector()
|
||||
groups, err := inspector.Groups(qname)
|
||||
if len(groups) == 0 {
|
||||
fmt.Printf("No groups found in queue %q\n", qname)
|
||||
return
|
||||
}
|
||||
for _, g := range groups {
|
||||
fmt.Println(g.Group)
|
||||
}
|
||||
}
|
@ -5,7 +5,7 @@ go 1.13
|
||||
require (
|
||||
github.com/fatih/color v1.9.0
|
||||
github.com/go-redis/redis/v8 v8.11.4
|
||||
github.com/hibiken/asynq v0.21.0 /* TODO: Update this after release */
|
||||
github.com/hibiken/asynq v0.21.0
|
||||
github.com/hibiken/asynq/x v0.0.0-20220131170841-349f4c50fb1d
|
||||
github.com/mitchellh/go-homedir v1.1.0
|
||||
github.com/prometheus/client_golang v1.11.0
|
||||
@ -14,5 +14,4 @@ require (
|
||||
github.com/spf13/viper v1.7.0
|
||||
)
|
||||
|
||||
/* TODO: Remove this before release */
|
||||
replace github.com/hibiken/asynq => ../
|
||||
|
Loading…
Reference in New Issue
Block a user