Allow for update of connector status

meroxa · Mar 5, 2021 · 231d086 · 231d086
1 parent 4772c41
commit 231d086
Show file tree

Hide file tree

Showing 37 changed files with 160 additions and 34 deletions.
diff --git a/cmd/update.go b/cmd/update.go
@@ -0,0 +1,71 @@
+package cmd
+
+import (
+	"context"
+	"errors"
+	"fmt"
+	"time"
+
+	"github.com/meroxa/cli/display"
+	"github.com/spf13/cobra"
+)
+
+var (
+	state string // connector state
+)
+
+// updateCmd represents the update command
+var updateCmd = &cobra.Command{
+	Use:   "update",
+	Short: "Update a component",
+	Long:  `Update a component of the Meroxa platform, including connectors`,
+}
+
+var updateConnectorCmd = &cobra.Command{
+	Use:   "connector <name> --state <pause|resume|restart>",
+	Short: "Update connector state",
+	RunE: func(cmd *cobra.Command, args []string) error {
+		if len(args) < 1 {
+			return errors.New("requires connector name\n\nUsage:\n  meroxa update connector <name> --state <state>")
+		}
+
+		// Connector Name
+		conName := args[0]
+
+		c, err := client()
+		if err != nil {
+			return err
+		}
+
+		ctx := context.Background()
+		ctx, cancel := context.WithTimeout(ctx, 5*time.Second)
+		defer cancel()
+
+		// call meroxa-go to update connector status with name
+		if !flagRootOutputJSON {
+			fmt.Printf("Updating %s connector...\n", conName)
+		}
+
+		con, err := c.UpdateConnectorStatus(ctx, conName, state)
+		if err != nil {
+			return err
+		}
+
+		if flagRootOutputJSON {
+			display.JSONPrint(con)
+		} else {
+			fmt.Printf("Connector %s successfully updated!\n", con.Name)
+		}
+
+		return nil
+	},
+}
+
+func init() {
+	RootCmd.AddCommand(updateCmd)
+
+	// Subcommands
+	updateCmd.AddCommand(updateConnectorCmd)
+	updateConnectorCmd.Flags().StringVarP(&state, "state", "", "", "connector state")
+	updateConnectorCmd.MarkFlagRequired("state")
+}
diff --git a/docs/commands/meroxa.md b/docs/commands/meroxa.md
@@ -35,6 +35,7 @@ meroxa list resource-types
 * [meroxa logs](meroxa_logs.md)	 - Print logs for a component
 * [meroxa open](meroxa_open.md)	 - Open in a web browser
 * [meroxa remove](meroxa_remove.md)	 - Remove a component
+* [meroxa update](meroxa_update.md)	 - Update a component
 * [meroxa version](meroxa_version.md)	 - Display the Meroxa CLI version
 
-###### Auto generated by spf13/cobra on 4-Mar-2021
+###### Auto generated by spf13/cobra on 5-Mar-2021
diff --git a/docs/commands/meroxa_add.md b/docs/commands/meroxa_add.md
@@ -20,4 +20,4 @@ Add a resource to your Meroxa resource catalog
 * [meroxa](meroxa.md)	 - The Meroxa CLI
 * [meroxa add resource](meroxa_add_resource.md)	 - Add a resource to your Meroxa resource catalog
 
-###### Auto generated by spf13/cobra on 4-Mar-2021
+###### Auto generated by spf13/cobra on 5-Mar-2021
diff --git a/docs/commands/meroxa_add_resource.md b/docs/commands/meroxa_add_resource.md
@@ -42,4 +42,4 @@ meroxa add resource slack --type url -u $WEBHOOK_URL
 
 * [meroxa add](meroxa_add.md)	 - Add a resource to your Meroxa resource catalog
 
-###### Auto generated by spf13/cobra on 4-Mar-2021
+###### Auto generated by spf13/cobra on 5-Mar-2021
diff --git a/docs/commands/meroxa_api.md b/docs/commands/meroxa_api.md
@@ -31,4 +31,4 @@ meroxa api POST /v1/endpoints '{"protocol": "HTTP", "stream": "resource-2-499379
 
 * [meroxa](meroxa.md)	 - The Meroxa CLI
 
-###### Auto generated by spf13/cobra on 4-Mar-2021
+###### Auto generated by spf13/cobra on 5-Mar-2021
diff --git a/docs/commands/meroxa_billing.md b/docs/commands/meroxa_billing.md
@@ -23,4 +23,4 @@ meroxa billing [flags]
 
 * [meroxa](meroxa.md)	 - The Meroxa CLI
 
-###### Auto generated by spf13/cobra on 4-Mar-2021
+###### Auto generated by spf13/cobra on 5-Mar-2021
diff --git a/docs/commands/meroxa_completion.md b/docs/commands/meroxa_completion.md
@@ -57,4 +57,4 @@ meroxa completion [bash|zsh|fish|powershell]
 
 * [meroxa](meroxa.md)	 - The Meroxa CLI
 
-###### Auto generated by spf13/cobra on 4-Mar-2021
+###### Auto generated by spf13/cobra on 5-Mar-2021
diff --git a/docs/commands/meroxa_connect.md b/docs/commands/meroxa_connect.md
@@ -42,4 +42,4 @@ meroxa connect --from <resource-name> --to <resource-name> [flags]
 
 * [meroxa](meroxa.md)	 - The Meroxa CLI
 
-###### Auto generated by spf13/cobra on 4-Mar-2021
+###### Auto generated by spf13/cobra on 5-Mar-2021
diff --git a/docs/commands/meroxa_create.md b/docs/commands/meroxa_create.md
@@ -27,4 +27,4 @@ including connectors.
 * [meroxa create endpoint](meroxa_create_endpoint.md)	 - Create an endpoint
 * [meroxa create pipeline](meroxa_create_pipeline.md)	 - Create a pipeline
 
-###### Auto generated by spf13/cobra on 4-Mar-2021
+###### Auto generated by spf13/cobra on 5-Mar-2021
diff --git a/docs/commands/meroxa_create_connector.md b/docs/commands/meroxa_create_connector.md
@@ -38,4 +38,4 @@ meroxa create connector [<custom-connector-name>] --to pg2redshift --input order
 
 * [meroxa create](meroxa_create.md)	 - Create Meroxa pipeline components
 
-###### Auto generated by spf13/cobra on 4-Mar-2021
+###### Auto generated by spf13/cobra on 5-Mar-2021
diff --git a/docs/commands/meroxa_create_endpoint.md b/docs/commands/meroxa_create_endpoint.md
@@ -36,4 +36,4 @@ meroxa create endpoint my-endpoint --protocol http --stream my-stream
 
 * [meroxa create](meroxa_create.md)	 - Create Meroxa pipeline components
 
-###### Auto generated by spf13/cobra on 4-Mar-2021
+###### Auto generated by spf13/cobra on 5-Mar-2021
diff --git a/docs/commands/meroxa_create_pipeline.md b/docs/commands/meroxa_create_pipeline.md
@@ -24,4 +24,4 @@ meroxa create pipeline <name> [flags]
 
 * [meroxa create](meroxa_create.md)	 - Create Meroxa pipeline components
 
-###### Auto generated by spf13/cobra on 4-Mar-2021
+###### Auto generated by spf13/cobra on 5-Mar-2021
diff --git a/docs/commands/meroxa_describe.md b/docs/commands/meroxa_describe.md
@@ -26,4 +26,4 @@ Describe a component of the Meroxa data platform, including resources and connec
 * [meroxa describe endpoint](meroxa_describe_endpoint.md)	 - Describe Endpoint
 * [meroxa describe resource](meroxa_describe_resource.md)	 - Describe resource
 
-###### Auto generated by spf13/cobra on 4-Mar-2021
+###### Auto generated by spf13/cobra on 5-Mar-2021
diff --git a/docs/commands/meroxa_describe_connector.md b/docs/commands/meroxa_describe_connector.md
@@ -23,4 +23,4 @@ meroxa describe connector [name] [flags]
 
 * [meroxa describe](meroxa_describe.md)	 - Describe a component
 
-###### Auto generated by spf13/cobra on 4-Mar-2021
+###### Auto generated by spf13/cobra on 5-Mar-2021
diff --git a/docs/commands/meroxa_describe_endpoint.md b/docs/commands/meroxa_describe_endpoint.md
@@ -23,4 +23,4 @@ meroxa describe endpoint <name> [flags]
 
 * [meroxa describe](meroxa_describe.md)	 - Describe a component
 
-###### Auto generated by spf13/cobra on 4-Mar-2021
+###### Auto generated by spf13/cobra on 5-Mar-2021
diff --git a/docs/commands/meroxa_describe_resource.md b/docs/commands/meroxa_describe_resource.md
@@ -23,4 +23,4 @@ meroxa describe resource <name> [flags]
 
 * [meroxa describe](meroxa_describe.md)	 - Describe a component
 
-###### Auto generated by spf13/cobra on 4-Mar-2021
+###### Auto generated by spf13/cobra on 5-Mar-2021
diff --git a/docs/commands/meroxa_list.md b/docs/commands/meroxa_list.md
@@ -30,4 +30,4 @@ List the components of the Meroxa platform, including pipelines,
 * [meroxa list resources](meroxa_list_resources.md)	 - List resources
 * [meroxa list transforms](meroxa_list_transforms.md)	 - List transforms
 
-###### Auto generated by spf13/cobra on 4-Mar-2021
+###### Auto generated by spf13/cobra on 5-Mar-2021
diff --git a/docs/commands/meroxa_list_connectors.md b/docs/commands/meroxa_list_connectors.md
@@ -23,4 +23,4 @@ meroxa list connectors [flags]
 
 * [meroxa list](meroxa_list.md)	 - List components
 
-###### Auto generated by spf13/cobra on 4-Mar-2021
+###### Auto generated by spf13/cobra on 5-Mar-2021
diff --git a/docs/commands/meroxa_list_endpoint.md b/docs/commands/meroxa_list_endpoint.md
@@ -23,4 +23,4 @@ meroxa list endpoint [flags]
 
 * [meroxa list](meroxa_list.md)	 - List components
 
-###### Auto generated by spf13/cobra on 4-Mar-2021
+###### Auto generated by spf13/cobra on 5-Mar-2021
diff --git a/docs/commands/meroxa_list_pipelines.md b/docs/commands/meroxa_list_pipelines.md
@@ -23,4 +23,4 @@ meroxa list pipelines [flags]
 
 * [meroxa list](meroxa_list.md)	 - List components
 
-###### Auto generated by spf13/cobra on 4-Mar-2021
+###### Auto generated by spf13/cobra on 5-Mar-2021
diff --git a/docs/commands/meroxa_list_resource-types.md b/docs/commands/meroxa_list_resource-types.md
@@ -23,4 +23,4 @@ meroxa list resource-types [flags]
 
 * [meroxa list](meroxa_list.md)	 - List components
 
-###### Auto generated by spf13/cobra on 4-Mar-2021
+###### Auto generated by spf13/cobra on 5-Mar-2021
diff --git a/docs/commands/meroxa_list_resources.md b/docs/commands/meroxa_list_resources.md
@@ -23,4 +23,4 @@ meroxa list resources [flags]
 
 * [meroxa list](meroxa_list.md)	 - List components
 
-###### Auto generated by spf13/cobra on 4-Mar-2021
+###### Auto generated by spf13/cobra on 5-Mar-2021
diff --git a/docs/commands/meroxa_list_transforms.md b/docs/commands/meroxa_list_transforms.md
@@ -23,4 +23,4 @@ meroxa list transforms [flags]
 
 * [meroxa list](meroxa_list.md)	 - List components
 
-###### Auto generated by spf13/cobra on 4-Mar-2021
+###### Auto generated by spf13/cobra on 5-Mar-2021
diff --git a/docs/commands/meroxa_login.md b/docs/commands/meroxa_login.md
@@ -23,4 +23,4 @@ meroxa login [flags]
 
 * [meroxa](meroxa.md)	 - The Meroxa CLI
 
-###### Auto generated by spf13/cobra on 4-Mar-2021
+###### Auto generated by spf13/cobra on 5-Mar-2021
diff --git a/docs/commands/meroxa_logout.md b/docs/commands/meroxa_logout.md
@@ -23,4 +23,4 @@ meroxa logout [flags]
 
 * [meroxa](meroxa.md)	 - The Meroxa CLI
 
-###### Auto generated by spf13/cobra on 4-Mar-2021
+###### Auto generated by spf13/cobra on 5-Mar-2021
diff --git a/docs/commands/meroxa_logs.md b/docs/commands/meroxa_logs.md
@@ -20,4 +20,4 @@ Print logs for a component
 * [meroxa](meroxa.md)	 - The Meroxa CLI
 * [meroxa logs connector](meroxa_logs_connector.md)	 - Print logs for a connector
 
-###### Auto generated by spf13/cobra on 4-Mar-2021
+###### Auto generated by spf13/cobra on 5-Mar-2021
diff --git a/docs/commands/meroxa_logs_connector.md b/docs/commands/meroxa_logs_connector.md
@@ -23,4 +23,4 @@ meroxa logs connector <name> [flags]
 
 * [meroxa logs](meroxa_logs.md)	 - Print logs for a component
 
-###### Auto generated by spf13/cobra on 4-Mar-2021
+###### Auto generated by spf13/cobra on 5-Mar-2021
diff --git a/docs/commands/meroxa_open.md b/docs/commands/meroxa_open.md
@@ -20,4 +20,4 @@ Open in a web browser
 * [meroxa](meroxa.md)	 - The Meroxa CLI
 * [meroxa open billing](meroxa_open_billing.md)	 - Open your billing page in a web browser
 
-###### Auto generated by spf13/cobra on 4-Mar-2021
+###### Auto generated by spf13/cobra on 5-Mar-2021
diff --git a/docs/commands/meroxa_open_billing.md b/docs/commands/meroxa_open_billing.md
@@ -23,4 +23,4 @@ meroxa open billing [flags]
 
 * [meroxa open](meroxa_open.md)	 - Open in a web browser
 
-###### Auto generated by spf13/cobra on 4-Mar-2021
+###### Auto generated by spf13/cobra on 5-Mar-2021
diff --git a/docs/commands/meroxa_remove.md b/docs/commands/meroxa_remove.md
@@ -28,4 +28,4 @@ Deprovision a component of the Meroxa platform, including pipelines,
 * [meroxa remove pipeline](meroxa_remove_pipeline.md)	 - Remove pipeline
 * [meroxa remove resource](meroxa_remove_resource.md)	 - Remove resource
 
-###### Auto generated by spf13/cobra on 4-Mar-2021
+###### Auto generated by spf13/cobra on 5-Mar-2021
diff --git a/docs/commands/meroxa_remove_connector.md b/docs/commands/meroxa_remove_connector.md
@@ -23,4 +23,4 @@ meroxa remove connector <name> [flags]
 
 * [meroxa remove](meroxa_remove.md)	 - Remove a component
 
-###### Auto generated by spf13/cobra on 4-Mar-2021
+###### Auto generated by spf13/cobra on 5-Mar-2021
diff --git a/docs/commands/meroxa_remove_endpoint.md b/docs/commands/meroxa_remove_endpoint.md
@@ -23,4 +23,4 @@ meroxa remove endpoint <name> [flags]
 
 * [meroxa remove](meroxa_remove.md)	 - Remove a component
 
-###### Auto generated by spf13/cobra on 4-Mar-2021
+###### Auto generated by spf13/cobra on 5-Mar-2021
diff --git a/docs/commands/meroxa_remove_pipeline.md b/docs/commands/meroxa_remove_pipeline.md
@@ -23,4 +23,4 @@ meroxa remove pipeline <name> [flags]
 
 * [meroxa remove](meroxa_remove.md)	 - Remove a component
 
-###### Auto generated by spf13/cobra on 4-Mar-2021
+###### Auto generated by spf13/cobra on 5-Mar-2021
diff --git a/docs/commands/meroxa_remove_resource.md b/docs/commands/meroxa_remove_resource.md
@@ -23,4 +23,4 @@ meroxa remove resource <name> [flags]
 
 * [meroxa remove](meroxa_remove.md)	 - Remove a component
 
-###### Auto generated by spf13/cobra on 4-Mar-2021
+###### Auto generated by spf13/cobra on 5-Mar-2021
diff --git a/docs/commands/meroxa_update.md b/docs/commands/meroxa_update.md
@@ -0,0 +1,27 @@
+## meroxa update
+
+Update a component
+
+### Synopsis
+
+Update a component of the Meroxa platform, including connectors
+
+### Options
+
+```
+  -h, --help   help for update
+```
+
+### Options inherited from parent commands
+
+```
+      --config string   config file (default is $HOME/meroxa.env)
+      --json            output json
+```
+
+### SEE ALSO
+
+* [meroxa](meroxa.md)	 - The Meroxa CLI
+* [meroxa update connector](meroxa_update_connector.md)	 - Update connector state
+
+###### Auto generated by spf13/cobra on 5-Mar-2021
diff --git a/docs/commands/meroxa_update_connector.md b/docs/commands/meroxa_update_connector.md
@@ -0,0 +1,27 @@
+## meroxa update connector
+
+Update connector state
+
+```
+meroxa update connector <name> --state <pause|resume|restart> [flags]
+```
+
+### Options
+
+```
+  -h, --help           help for connector
+      --state string   connector state
+```
+
+### Options inherited from parent commands
+
+```
+      --config string   config file (default is $HOME/meroxa.env)
+      --json            output json
+```
+
+### SEE ALSO
+
+* [meroxa update](meroxa_update.md)	 - Update a component
+
+###### Auto generated by spf13/cobra on 5-Mar-2021
diff --git a/docs/commands/meroxa_version.md b/docs/commands/meroxa_version.md
@@ -23,4 +23,4 @@ meroxa version [flags]
 
 * [meroxa](meroxa.md)	 - The Meroxa CLI
 
-###### Auto generated by spf13/cobra on 4-Mar-2021
+###### Auto generated by spf13/cobra on 5-Mar-2021