-
Notifications
You must be signed in to change notification settings - Fork 48
/
queries.go
42 lines (34 loc) · 1016 Bytes
/
queries.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
package queries
import (
"context"
"github.com/kubemq-io/kubemq-community/config"
"github.com/kubemq-io/kubemq-community/pkg/utils"
"github.com/spf13/cobra"
)
var queriesExamples = `
# Execute send 'queries' command
kubemq queries send
# Execute receive 'queries' command
kubemq queries receive
# Execute attach to 'queries' command
kubemq queries attach query
`
var queriesLong = `Execute Kubemq 'queries' `
var queriesShort = `Execute Kubemq 'queries'`
func NewCmdQueries(ctx context.Context, cfg *config.Config) *cobra.Command {
cmd := &cobra.Command{
Use: "queries",
Aliases: []string{"query", "qry"},
Short: queriesShort,
Long: queriesLong,
Example: queriesExamples,
ValidArgs: []string{"send", "receive", "attach"},
Run: func(cmd *cobra.Command, args []string) {
utils.CheckErr(cmd.Help())
},
}
cmd.AddCommand(NewCmdQueriesSend(ctx, cfg))
cmd.AddCommand(NewCmdQueriesReceive(ctx, cfg))
cmd.AddCommand(NewCmdQueriesAttach(ctx, cfg))
return cmd
}