-
Notifications
You must be signed in to change notification settings - Fork 72
/
consumergroup.go
30 lines (26 loc) · 1.13 KB
/
consumergroup.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
package consumergroup
import (
"github.com/redhat-developer/app-services-cli/pkg/cmd/kafka/consumergroup/delete"
"github.com/redhat-developer/app-services-cli/pkg/cmd/kafka/consumergroup/describe"
"github.com/redhat-developer/app-services-cli/pkg/cmd/kafka/consumergroup/list"
"github.com/redhat-developer/app-services-cli/pkg/cmd/kafka/consumergroup/resetoffset"
"github.com/redhat-developer/app-services-cli/pkg/shared/factory"
"github.com/spf13/cobra"
)
// NewConsumerGroupCommand creates a new command sub-group for consumer group operations
func NewConsumerGroupCommand(f *factory.Factory) *cobra.Command {
cmd := &cobra.Command{
Use: "consumer-group",
Short: f.Localizer.MustLocalize("kafka.consumerGroup.cmd.shortDescription"),
Long: f.Localizer.MustLocalize("kafka.consumerGroup.cmd.longDescription"),
Example: f.Localizer.MustLocalize("kafka.consumerGroup.cmd.example"),
Args: cobra.ExactArgs(1),
}
cmd.AddCommand(
list.NewListConsumerGroupCommand(f),
delete.NewDeleteConsumerGroupCommand(f),
describe.NewDescribeConsumerGroupCommand(f),
resetoffset.NewResetOffsetConsumerGroupCommand(f),
)
return cmd
}