cli/internal/flink/command_environment.go at 4bf809666ba0ca5797f63e6d15b287f110d57a0c · confluentinc/cli · GitHub

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
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
package flink

import (
	"github.com/spf13/cobra"

	cmfsdk "github.com/confluentinc/cmf-sdk-go/v1"

	pcmd "github.com/confluentinc/cli/v4/pkg/cmd"
)

type flinkEnvironmentOutput struct {
	Name                         string `human:"Name" serialized:"name"`
	KubernetesNamespace          string `human:"Kubernetes Namespace" serialized:"kubernetes_namespace"`
	KubernetesClusterName        string `human:"Kubernetes Cluster Name,omitempty" serialized:"kubernetes_cluster_name,omitempty"`
	CreatedTime                  string `human:"Created Time" serialized:"created_time"`
	UpdatedTime                  string `human:"Updated Time" serialized:"updated_time"`
	FlinkApplicationDefaults     string `human:"Flink Application Defaults,omitempty" serialized:"flink_application_defaults,omitempty"`
	ComputePoolDefaults          string `human:"Flink Compute Pool Defaults,omitempty" serialized:"flink_compute_pool_defaults,omitempty"`
	DetachedStatementDefaults    string `human:"Detached Statement Defaults,omitempty" serialized:"detached_statement_defaults,omitempty"`
	InteractiveStatementDefaults string `human:"Interactive Statement Defaults,omitempty" serialized:"interactive_statement_defaults,omitempty"`
}

func (c *command) newEnvironmentCommand() *cobra.Command {
	cmd := &cobra.Command{
		Use:         "environment",
		Short:       "Manage Flink environments.",
		Aliases:     []string{"env"},
		Annotations: map[string]string{pcmd.RunRequirement: pcmd.RequireCloudLogout},
	}

	cmd.AddCommand(c.newEnvironmentCreateCommand())
	cmd.AddCommand(c.newEnvironmentDeleteCommand())
	cmd.AddCommand(c.newEnvironmentDescribeCommand())
	cmd.AddCommand(c.newEnvironmentListCommand())
	cmd.AddCommand(c.newEnvironmentUpdateCommand())

	return cmd
}

func convertSdkEnvironmentToLocalEnvironment(sdkOutputEnvironment cmfsdk.Environment) LocalEnvironment {
	localEnv := LocalEnvironment{
		Secrets:                  sdkOutputEnvironment.Secrets,
		Name:                     sdkOutputEnvironment.Name,
		CreatedTime:              sdkOutputEnvironment.CreatedTime,
		UpdatedTime:              sdkOutputEnvironment.UpdatedTime,
		FlinkApplicationDefaults: sdkOutputEnvironment.FlinkApplicationDefaults,
		KubernetesNamespace:      sdkOutputEnvironment.KubernetesNamespace,
		KubernetesClusterName:    sdkOutputEnvironment.GetKubernetesClusterName(),
		ComputePoolDefaults:      sdkOutputEnvironment.ComputePoolDefaults,
	}

	if sdkOutputEnvironment.StatementDefaults != nil {
		localDefaults1 := &LocalAllStatementDefaults1{}

		if sdkOutputEnvironment.StatementDefaults.Detached != nil {
			localDefaults1.Detached = &LocalStatementDefaults{
				FlinkConfiguration: sdkOutputEnvironment.StatementDefaults.Detached.FlinkConfiguration,
			}
		}

		if sdkOutputEnvironment.StatementDefaults.Interactive != nil {
			localDefaults1.Interactive = &LocalStatementDefaults{
				FlinkConfiguration: sdkOutputEnvironment.StatementDefaults.Interactive.FlinkConfiguration,
			}
		}

		localEnv.StatementDefaults = localDefaults1
	}

	return localEnv
}