Skip to content

Commit e0ef5cc

Browse files
committed
Add cluster ID to all outputs
1 parent 715ea37 commit e0ef5cc

File tree

2 files changed

+15
-15
lines changed

2 files changed

+15
-15
lines changed

command/connect/command.go

Lines changed: 13 additions & 13 deletions
Original file line numberDiff line numberDiff line change
@@ -22,9 +22,9 @@ import (
2222
)
2323

2424
var (
25-
listFields = []string{"Name", "Plugin", "ServiceProvider", "Region", "Status"}
26-
listLabels = []string{"Name", "Kind", "Provider", "Region", "Status"}
27-
describeFields = []string{"Name", "Plugin", "KafkaClusterId", "ServiceProvider", "Region", "Durability", "Status"}
25+
listFields = []string{"Id", "Name", "Plugin", "ServiceProvider", "Region", "Status"}
26+
listLabels = []string{"Id", "Name", "Kind", "Provider", "Region", "Status"}
27+
describeFields = []string{"Id", "Name", "Plugin", "KafkaClusterId", "ServiceProvider", "Region", "Durability", "Status"}
2828
describeRenames = map[string]string{"Plugin": "Kind", "KafkaClusterId": "Kafka", "ServiceProvider": "Provider"}
2929
validPluginTypes = []string{"s3-sink"}
3030
)
@@ -94,7 +94,7 @@ func (c *command) init() error {
9494
}
9595

9696
createCmd := &cobra.Command{
97-
Use: "create <name>",
97+
Use: "create NAME",
9898
Short: "Create a connector.",
9999
RunE: c.create,
100100
}
@@ -115,7 +115,7 @@ func (c *command) init() error {
115115
})
116116

117117
getCmd := &cobra.Command{
118-
Use: "get <name>",
118+
Use: "get NAME",
119119
Short: "Get a connector.",
120120
RunE: c.get,
121121
Args: cobra.ExactArgs(1),
@@ -124,20 +124,14 @@ func (c *command) init() error {
124124
c.AddCommand(getCmd)
125125

126126
c.AddCommand(&cobra.Command{
127-
Use: "describe <name>",
127+
Use: "describe NAME",
128128
Short: "Describe a connector.",
129129
RunE: c.describe,
130130
Args: cobra.ExactArgs(1),
131131
})
132132

133-
c.AddCommand(&cobra.Command{
134-
Use: "delete",
135-
Short: "Delete a connector.",
136-
RunE: c.delete,
137-
})
138-
139133
updateCmd := &cobra.Command{
140-
Use: "update <name>",
134+
Use: "update NAME",
141135
Short: "Update a connector.",
142136
RunE: c.update,
143137
Args: cobra.ExactArgs(1),
@@ -146,6 +140,12 @@ func (c *command) init() error {
146140
check(updateCmd.MarkFlagRequired("config"))
147141
c.AddCommand(updateCmd)
148142

143+
c.AddCommand(&cobra.Command{
144+
Use: "delete NAME",
145+
Short: "Delete a connector.",
146+
RunE: c.delete,
147+
})
148+
149149
c.AddCommand(&cobra.Command{
150150
Use: "auth",
151151
Short: "Auth a connector.",

command/kafka/command.go

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -17,8 +17,8 @@ import (
1717
)
1818

1919
var (
20-
listFields = []string{"Name", "ServiceProvider", "Region", "Durability", "Status"}
21-
listLabels = []string{"Name", "Provider", "Region", "Durability", "Status"}
20+
listFields = []string{"Id", "Name", "ServiceProvider", "Region", "Durability", "Status"}
21+
listLabels = []string{"Id", "Name", "Provider", "Region", "Durability", "Status"}
2222
describeFields = []string{"Id", "Name", "NetworkIngress", "NetworkEgress", "Storage", "ServiceProvider", "Region", "Status", "Endpoint", "PricePerHour"}
2323
describeRenames = map[string]string{"NetworkIngress": "Ingress", "NetworkEgress": "Egress", "ServiceProvider": "Provider"}
2424
)

0 commit comments

Comments
 (0)