cluster.go

// Copyright © 2020 Simon Fuhrer
//
// Licensed under the Apache License, Version 2.0 (the "License");
// you may not use this file except in compliance with the License.
// You may obtain a copy of the License at
//
//     http://www.apache.org/licenses/LICENSE-2.0
//
// Unless required by applicable law or agreed to in writing, software
// distributed under the License is distributed on an "AS IS" BASIS,
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
// See the License for the specific language governing permissions and
// limitations under the License.

package displayers

import (
	"fmt"
	"io"
	"sort"
	"strconv"
	"strings"

	"github.com/tecbiz-ch/nutanix-go-sdk/schema"
)

// Clusters wraps a nutanix ImageListIntent.
type Clusters struct {
	schema.ClusterListIntent
}

// var _ Displayable = &Clusters{}

func (o Clusters) JSON(w io.Writer) error {
	return DisplayJSON(w, o.Entities)
}

func (o Clusters) JSONPath(w io.Writer, template string) error {
	return DisplayJSONPath(w, template, o.Entities)
}

func (o Clusters) PP(w io.Writer) error {
	return DisplayPP(w, o.Entities)
}

func (o Clusters) YAML(w io.Writer) error {
	return DisplayYAML(w, o.Entities)
}

func (o Clusters) header() []string {
	return []string{
		"UUID",
		"Name",
		"AOS Version",
		"Operation Mode",
		"Hypervisor",
		"Hosts",
		"Inefficient VMs",
		"ExternalIP",
		"Categories",
	}
}

func (o Clusters) TableData(w io.Writer) error {
	data := make([][]string, len(o.Entities))
	for i, cluster := range o.Entities {
		if cluster.Spec.Name == "Unnamed" || strings.Compare(*cluster.Status.Resources.Config.Build.Version, "pc") == 0 {
			continue
		}
		var hosts = 0
		hypervisor := ""
		if cluster.Status.Resources.Nodes != nil {
			hypervisor = cluster.Status.Resources.Nodes.HypervisorServerList[0].Type
			for _, host := range cluster.Status.Resources.Nodes.HypervisorServerList {
				if host.IP != "127.0.0.1" {
					hosts++

				}
			}

		}
		categories := []string{}
		if cluster.Metadata.Categories != nil {
			for key, value := range cluster.Metadata.Categories {
				categories = append(categories, fmt.Sprintf("%s: %s", key, value))

			}

		}
		sort.Strings(categories)
		data[i] = []string{
			cluster.Metadata.UUID,
			cluster.Spec.Name,
			cluster.Spec.Resources.Config.SoftwareMap["NOS"].Version,
			cluster.Spec.Resources.Config.OperationMode,
			hypervisor,
			strconv.Itoa(hosts),
			*cluster.Status.Resources.Analysis.VMEfficiencyMap.InefficientVMNum,
			cluster.Spec.Resources.Network.ExternalIP,
			strings.Join(categories, ", "),
		}
	}
	return DisplayTable(w, data, o.header())
}

func (o Clusters) Text(w io.Writer) error {
	return nil
}