CLOUDP-333877: create stub for atlas cli commands streams workspaces and streams workspaces create

docs/command/atlas-streams-workspaces-create.txt

@@ -53,10 +53,18 @@ Options
      - Type
      - Required
      - Description
+   * - --defaultTier
+     - string
+     - false
+     - Default Tier for your Stream Workspace.
    * - -h, --help
      - 
      - false
      - help for create
+   * - --maxTierSize
+     - string
+     - false
+     - Max Tier Size for your Stream Workspace.
    * - -o, --output
      - string
      - false

internal/cli/streams/instance/create.go

@@ -38,11 +38,13 @@ type CreateOpts struct {
 	cli.ProjectOpts
 	cli.OutputOpts
 	cli.InputOpts
-	name     string
-	provider string
-	region   string
-	tier     string
-	store    StreamsCreator
+	name        string
+	provider    string
+	region      string
+	tier        string
+	defaultTier string
+	maxTierSize string
+	store       StreamsCreator
 }
 
 const (
@@ -160,6 +162,8 @@ func WorkspaceCreateBuilder() *cobra.Command {
 	opts.AddOutputOptFlags(cmd)
 
 	cmd.Flags().StringVar(&opts.tier, flag.Tier, "SP30", usage.StreamsWorkspaceTier)
+	cmd.Flags().StringVar(&opts.defaultTier, flag.DefaultTier, "", usage.StreamsWorkspaceDefaultTier)
+	cmd.Flags().StringVar(&opts.maxTierSize, flag.MaxTierSize, "", usage.StreamsWorkspaceMaxTierSize)
 
 	_ = cmd.MarkFlagRequired(flag.Provider)
 	_ = cmd.MarkFlagRequired(flag.Region)

internal/cli/streams/instance/create_test.go

@@ -131,4 +131,42 @@ func TestCreateOpts_Run(t *testing.T) {
 		t.Log(buf.String())
 		test.VerifyOutputTemplate(t, createWorkspace, expected)
 	})
+
+	t.Run("stream workspaces create --tier --defaultTier --maxTierSize", func(t *testing.T) {
+		buf := new(bytes.Buffer)
+		opts := &CreateOpts{
+			store:       mockStore,
+			name:        "ExampleStreamWorkspaces",
+			provider:    "AWS",
+			region:      "VIRGINIA_USA",
+			tier:        "SP30",
+			defaultTier: "SP30",
+			maxTierSize: "SP50",
+		}
+		opts.ProjectID = testProjectID
+
+		expected := &atlasv2.StreamsTenant{
+			Name:              &opts.name,
+			GroupId:           &opts.ProjectID,
+			DataProcessRegion: &atlasv2.StreamsDataProcessRegion{CloudProvider: "AWS", Region: "VIRGINIA_USA"},
+			StreamConfig: &atlasv2.StreamConfig{
+				Tier: &opts.tier,
+				// Testing the parsing of flags but not passing into StreamConfig object
+				// DefaultTier: &opts.defaultTier,
+				// MaxTierSize: &opts.maxTierSize,
+			},
+		}
+
+		mockStore.
+			EXPECT().
+			CreateStream(opts.ProjectID, expected).
+			Return(expected, nil).
+			Times(1)
+
+		if err := opts.Run(); err != nil {
+			t.Fatalf("Run() unexpected error: %v", err)
+		}
+		t.Log(buf.String())
+		test.VerifyOutputTemplate(t, createWorkspace, expected)
+	})
 }