Skip to content
This repository has been archived by the owner on Jul 25, 2022. It is now read-only.

Add garden show infra cmd #495

Merged
merged 1 commit into from
May 14, 2021
Merged

Add garden show infra cmd #495

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
8 changes: 6 additions & 2 deletions pkg/cmd/operate.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -204,9 +204,13 @@ func operate(provider, arguments string) string {
if err != nil {
os.Exit(2)
}
err = ExecCmd(nil, arguments, false)

args := strings.Fields(arguments)
cmd := exec.Command("aliyun", args...)
out, err = cmd.CombinedOutput()
if err != nil {
os.Exit(2)
fmt.Println(err)
log.Fatalf("Aliyun CLI failed with %s\n%s\n", out, err)
}
}
return (strings.TrimSpace(string(out[:])))
Expand Down
205 changes: 199 additions & 6 deletions pkg/cmd/show.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -30,14 +30,18 @@ import (
"k8s.io/client-go/tools/clientcmd"
)

var (
flagoutput string
)

// NewShowCmd returns a new show command.
func NewShowCmd(targetReader TargetReader) *cobra.Command {
return &cobra.Command{
Use: "show (operator|gardener-dashboard|api|scheduler|controller-manager|etcd-operator|etcd-main|etcd-events|addon-manager|vpn-seed|vpn-shoot|machine-controller-manager|kubernetes-dashboard|prometheus|grafana|tf (infra|dns|ingress)|cluster-autoscaler)",
Short: "Show details about endpoint/service and open in default browser if applicable, e.g. \"gardenctl show scheduler\" show scheduler pod of current shoot",
cmd := &cobra.Command{
Use: "show (infra|operator|gardener-dashboard|api|scheduler|controller-manager|etcd-operator|etcd-main|etcd-events|addon-manager|vpn-seed|vpn-shoot|machine-controller-manager|kubernetes-dashboard|prometheus|grafana|tf (infra|dns|ingress)|cluster-autoscaler)",
Short: `Show details about endpoint/service and open in default browser if applicable`,
RunE: func(cmd *cobra.Command, args []string) error {
if len(args) < 1 || len(args) > 2 {
return errors.New("Command must be in the format: show (operator|gardener-dashboard|api|scheduler|controller-manager|etcd-operator|etcd-main|etcd-events|addon-manager|vpn-seed|vpn-shoot|machine-controller-manager|kubernetes-dashboard|prometheus|grafana|tf (infra|dns|ingress)|cluster-autoscaler)")
return errors.New("Command must be in the format: show (infra|operator|gardener-dashboard|api|scheduler|controller-manager|etcd-operator|etcd-main|etcd-events|addon-manager|vpn-seed|vpn-shoot|machine-controller-manager|kubernetes-dashboard|prometheus|grafana|tf (infra|dns|ingress)|cluster-autoscaler)")
}
t := targetReader.ReadTarget(pathTarget)
if (len(t.Stack()) < 3 || (len(t.Stack()) == 3 && t.Stack()[2].Kind == "namespace")) && (args[0] != "operator") && (args[0] != "tf") && (args[0] != "kubernetes-dashboard") && (args[0] != "etcd-operator") {
Expand All @@ -54,6 +58,11 @@ func NewShowCmd(targetReader TargetReader) *cobra.Command {
// Set up global map variable targetInfo and key validation check

switch args[0] {
case "infra":
if flagoutput == "" {
flagoutput = "json"
}
showCloudInfra(targetReader, flagoutput)
case "operator":
showOperator()
case "gardener-dashboard":
Expand Down Expand Up @@ -97,17 +106,20 @@ func NewShowCmd(targetReader TargetReader) *cobra.Command {
case "ingress":
showIngress()
default:
fmt.Println("Command must be in the format: show (operator|gardener-dashboard|api|scheduler|controller-manager|etcd-operator|etcd-main|etcd-events|addon-manager|vpn-seed|vpn-shoot|machine-controller-manager|kubernetes-dashboard|prometheus|grafana|tf (infra|dns|ingress)|cluster-autoscaler)")
fmt.Println("Command must be in the format: show (infra|operator|gardener-dashboard|api|scheduler|controller-manager|etcd-operator|etcd-main|etcd-events|addon-manager|vpn-seed|vpn-shoot|machine-controller-manager|kubernetes-dashboard|prometheus|grafana|tf (infra|dns|ingress)|cluster-autoscaler)")
}
case "cluster-autoscaler":
showClusterAutoscaler(targetReader)
default:
fmt.Println("Command must be in the format: show (operator|gardener-dashboard|api|scheduler|controller-manager|etcd-operator|etcd-main|etcd-events|addon-manager|vpn-seed|vpn-shoot|machine-controller-manager|kubernetes-dashboard|prometheus|grafana|tf (infra|dns|ingress)|cluster-autoscaler)")
fmt.Println("Command must be in the format: show (infra|operator|gardener-dashboard|api|scheduler|controller-manager|etcd-operator|etcd-main|etcd-events|addon-manager|vpn-seed|vpn-shoot|machine-controller-manager|kubernetes-dashboard|prometheus|grafana|tf (infra|dns|ingress)|cluster-autoscaler)")
}
return nil
},
ValidArgs: []string{"operator", "gardener-dashboard", "api", "scheduler", "controller-manager", "etcd-operator", "etcd-main", "etcd-events", "addon-manager", "vpn-seed", "vpn-shoot", "machine-controller-manager", "kubernetes-dashboard", "prometheus", "grafana", "tf", "cluster-autoscaler"},
}

cmd.PersistentFlags().StringVarP(&flagoutput, "format", "f", "", "output format (default: json)")
return cmd
}

// showPodGarden
Expand Down Expand Up @@ -197,6 +209,187 @@ func showPod(toMatch string, toTarget TargetKind, targetReader TargetReader) {
}
}

// showCloudInfra shows the infra resources for the targeted shoot cluster
func showCloudInfra(targetReader TargetReader, output string) {
target := targetReader.ReadTarget(pathTarget)
shoot, err := FetchShootFromTarget(target)
checkError(err)
infraType := shoot.Spec.Provider.Type

switch infraType {
case "aws":
showCloudInfraTypeAWS(targetReader, output)
case "azure":
showCloudInfraTypeAzure(targetReader, output)
case "gcp":
showCloudInfraTypeGCP(targetReader, output)
case "openstack":
showCloudInfraTypeOpenstack(targetReader, output)
case "alicloud":
showCloudInfraTypeAlicloud(targetReader)
default:
fmt.Println("infra type not found")
}
}

// showCloudInfraTypeAWS shows the AWS infra resources for the targeted shoot cluster
func showCloudInfraTypeAWS(targetReader TargetReader, output string) {

shoottag := GetFromTargetInfo(targetReader, "shootTechnicalID")

capturedOutput := execInfraOperator("aws", "ec2 describe-instances --filter Name=tag:kubernetes.io/cluster/"+shoottag+",Values=1 --output "+output)
fmt.Println(capturedOutput)

capturedOutput = execInfraOperator("aws", "ec2 describe-volumes --filter Name=tag:kubernetes.io/cluster/"+shoottag+",Values=1 --output "+output)
fmt.Println(capturedOutput)

capturedOutput = execInfraOperator("aws", "ec2 describe-vpcs --filter Name=tag:kubernetes.io/cluster/"+shoottag+",Values=1 --output "+output)
fmt.Println(capturedOutput)

capturedOutput = execInfraOperator("aws", "ec2 describe-subnets --filter Name=tag:kubernetes.io/cluster/"+shoottag+",Values=1 --output "+output)
fmt.Println(capturedOutput)

capturedOutput = execInfraOperator("aws", "ec2 describe-route-tables --filter Name=tag:kubernetes.io/cluster/"+shoottag+",Values=1 --output "+output)
fmt.Println(capturedOutput)

capturedOutput = execInfraOperator("aws", "ec2 describe-security-groups --filter Name=tag:kubernetes.io/cluster/"+shoottag+",Values=1 --output "+output)
fmt.Println(capturedOutput)

capturedOutput = execInfraOperator("aws", "ec2 describe-internet-gateways --filter Name=tag:kubernetes.io/cluster/"+shoottag+",Values=1 --output "+output)
fmt.Println(capturedOutput)

capturedOutput = execInfraOperator("aws", "ec2 describe-nat-gateways --filter Name=tag:kubernetes.io/cluster/"+shoottag+",Values=1 --output "+output)
fmt.Println(capturedOutput)

capturedOutput = execInfraOperator("aws", "ec2 describe-addresses --filter Name=tag:kubernetes.io/cluster/"+shoottag+",Values=1 --output "+output)
fmt.Println(capturedOutput)
}

// showCloudInfraTypeAzure shows the Azure infra resources for the targeted shoot cluster
func showCloudInfraTypeAzure(targetReader TargetReader, output string) {

shoottag := GetFromTargetInfo(targetReader, "shootTechnicalID")

capturedOutput := execInfraOperator("az", "vm list -d -g "+shoottag+" --output "+output)
fmt.Println(capturedOutput)

capturedOutput = execInfraOperator("az", "disk list -g "+shoottag+" --output "+output)
fmt.Println(capturedOutput)

capturedOutput = execInfraOperator("az", "network vnet list -g "+shoottag+" --output "+output)
fmt.Println(capturedOutput)

vnets := make([]string, 0)
vnets = findInfraResourcesMatch(`\"id\".*(virtualNetworks\/[a-z0-9-]*)\"`, capturedOutput, vnets)
if len(vnets) > 0 {
for _, vnet := range vnets {
s := strings.Split(vnet, "/")
vnetName := s[1]
capturedOutput = execInfraOperator("az", "network vnet subnet list -g "+shoottag+" --vnet-name "+vnetName+" --output "+output)
fmt.Println(capturedOutput)
}
}

capturedOutput = execInfraOperator("az", "network route-table list -g "+shoottag+" --output "+output)
fmt.Println(capturedOutput)

capturedOutput = execInfraOperator("az", "network nsg list -g "+shoottag+" --output "+output)
fmt.Println(capturedOutput)

capturedOutput = execInfraOperator("az", "network lb list -g "+shoottag+" --output "+output)
fmt.Println(capturedOutput)

capturedOutput = execInfraOperator("az", "network nic list -g "+shoottag+" --output "+output)
fmt.Println(capturedOutput)

capturedOutput = execInfraOperator("az", "network public-ip list -g "+shoottag+" --output "+output)
fmt.Println(capturedOutput)
}

// showCloudInfraTypeGCP shows the GCP infra resources for the targeted shoot cluster
func showCloudInfraTypeGCP(targetReader TargetReader, output string) {

shoottag := GetFromTargetInfo(targetReader, "shootTechnicalID")

capturedOutput := execInfraOperator("gcp", "compute instances list --filter=name~"+shoottag+" --format "+output)
fmt.Println(capturedOutput)

capturedOutput = execInfraOperator("gcp", "compute disks list --filter=name~"+shoottag+" --format "+output)
fmt.Println(capturedOutput)

capturedOutput = execInfraOperator("gcp", "compute networks list --filter=name="+shoottag+" --format "+output)
fmt.Println(capturedOutput)

capturedOutput = execInfraOperator("gcp", "compute networks subnets list --filter=name~"+shoottag+" --format "+output)
fmt.Println(capturedOutput)

capturedOutput = execInfraOperator("gcp", "compute routers list --filter=name~"+shoottag+" --format "+output)
fmt.Println(capturedOutput)

capturedOutput = execInfraOperator("gcp", "compute routes list --filter=network="+shoottag+" --format "+output)
fmt.Println(capturedOutput)

capturedOutput = execInfraOperator("gcp", "compute firewall-rules list --filter=network="+shoottag+" --format "+output)
fmt.Println(capturedOutput)
}

// showCloudInfraTypeOpenstack shows the Openstack infra resources for the targeted shoot cluster
func showCloudInfraTypeOpenstack(targetReader TargetReader, output string) {

shoottag := GetFromTargetInfo(targetReader, "shootTechnicalID")

capturedOutput := execInfraOperator("openstack", "server list --name "+shoottag+".* --format "+output)
fmt.Println(capturedOutput)

capturedOutput = execInfraOperator("openstack", "volume list --format "+output)
fmt.Println(capturedOutput)

capturedOutput = execInfraOperator("openstack", "network list --name "+shoottag+" --format "+output)
fmt.Println(capturedOutput)

capturedOutput = execInfraOperator("openstack", "subnet list --name "+shoottag+" --format "+output)
fmt.Println(capturedOutput)

capturedOutput = execInfraOperator("openstack", "router list --name "+shoottag+" --format "+output)
fmt.Println(capturedOutput)

capturedOutput = execInfraOperator("openstack", "floating ip list --format "+output)
fmt.Println(capturedOutput)

capturedOutput = execInfraOperator("openstack", "security group list --format "+output)
fmt.Println(capturedOutput)
}

// showCloudInfraTypeAlicloud shows the Alicloud infra resources for the targeted shoot cluster
func showCloudInfraTypeAlicloud(targetReader TargetReader) {

shoottag := GetFromTargetInfo(targetReader, "shootTechnicalID")

capturedOutput := execInfraOperator("aliyun", "ecs DescribeInstances --InstanceName "+shoottag+"*")
fmt.Println(capturedOutput)

capturedOutput = execInfraOperator("aliyun", "ecs DescribeDisks")
fmt.Println(capturedOutput)

capturedOutput = execInfraOperator("aliyun", "vpc DescribeVpcs --VpcName "+shoottag+"-vpc")
fmt.Println(capturedOutput)

capturedOutput = execInfraOperator("aliyun", "ecs DescribeVSwitches")
fmt.Println(capturedOutput)

capturedOutput = execInfraOperator("aliyun", "ecs DescribeVRouters")
fmt.Println(capturedOutput)

capturedOutput = execInfraOperator("aliyun", "ecs DescribeRouteTables")
fmt.Println(capturedOutput)

capturedOutput = execInfraOperator("aliyun", "ecs DescribeEipAddresses")
fmt.Println(capturedOutput)

capturedOutput = execInfraOperator("aliyun", "ecs DescribeSecurityGroups --SecurityGroupName "+shoottag+"-sg")
fmt.Println(capturedOutput)
}

// showAPIServer shows the pod for the api-server running in the targeted seed cluster
func showAPIServer(targetReader TargetReader) {
showPod("kube-apiserver", "seed", targetReader)
Expand Down
2 changes: 1 addition & 1 deletion pkg/cmd/show_test.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -51,7 +51,7 @@ var _ = Describe("Show command", func() {
err := command.Execute()

Expect(err).To(HaveOccurred())
Expect(err.Error()).To(Equal("Command must be in the format: show (operator|gardener-dashboard|api|scheduler|controller-manager|etcd-operator|etcd-main|etcd-events|addon-manager|vpn-seed|vpn-shoot|machine-controller-manager|kubernetes-dashboard|prometheus|grafana|tf (infra|dns|ingress)|cluster-autoscaler)"))
Expect(err.Error()).To(Equal("Command must be in the format: show (infra|operator|gardener-dashboard|api|scheduler|controller-manager|etcd-operator|etcd-main|etcd-events|addon-manager|vpn-seed|vpn-shoot|machine-controller-manager|kubernetes-dashboard|prometheus|grafana|tf (infra|dns|ingress)|cluster-autoscaler)"))
})
})
})