Function combineKubeOpts has 7 return statements (exceeds 4 allowed).

Open

func combineKubeOpts() (err error) {
    var config *clientcmdapi.Config
    if opt.Get().Global.Kubeconfig != ""{
        // if kubeconfig specified, always read from it
        _ = os.Setenv(util.EnvKubeConfig, opt.Get().Global.Kubeconfig)

Avoid deeply nested control flow statements.

Open

        } else if util.IsMacos() {
            dnsPort = opt.Get().Connect.DnsPort
        }

Function createRouter has 7 return statements (exceeds 4 allowed).

Open

func createRouter(routerPodName string, svcName string, ports map[int]int, labels map[string]string, versionMark string) error {
    namespace := opt.Get().Global.Namespace
    routerPod, err := cluster.Ins().GetPod(routerPodName, namespace)
    if err == nil && routerPod.DeletionTimestamp != nil {
        routerPod, err = cluster.Ins().WaitPodTerminate(routerPodName, namespace)

Function AutoMesh has a Cognitive Complexity of 23 (exceeds 20 allowed). Consider refactoring.

Open

func AutoMesh(svc *coreV1.Service) error {
    // Lock service to avoid conflict, must be first step
    svc, err := general.LockService(svc.Name, opt.Get().Global.Namespace, 0)
    if err != nil {
        return err

• Read up
  Read up

Avoid deeply nested control flow statements.

Open

                if keepShortDomain {
                    recordsToKeep = append(recordsToKeep, l)
                }

Avoid deeply nested control flow statements.

Open

                    if _, err = strconv.Atoi(upstreamParts[1]); err == nil {
                        dnsAddresses = append(dnsAddresses, fmt.Sprintf("udp:%s:%s", upstreamDns, upstreamParts[1]))
                    } else {
                        dnsAddresses = append(dnsAddresses, fmt.Sprintf("%s:%s:%d", upstreamParts[0], upstreamDns, common.StandardDnsPort))
                    }

Function SaveProfile has 6 return statements (exceeds 4 allowed).

Open

func SaveProfile(args []string) error {
    if len(args) != 1 {
        return fmt.Errorf("must specifiy a profile name")
    }
    profile := profileFile(args[0])

Function Mesh has 6 return statements (exceeds 4 allowed).

Open

func Mesh(resourceName string) error {
    ch, err := general.SetupProcess(util.ComponentMesh)
    if err != nil {
        return err
    }

Function Show has 6 return statements (exceeds 4 allowed).

Open

func Show(args []string) error {
    if len(args) > 0 {
        return fmt.Errorf("parameter '%s' is invalid", args[0])
    }
    customConfig := loadCustomConfig()

Function parsePort has 6 return statements (exceeds 4 allowed).

Open

func parsePort(args []string) (localPort int, remotePort int, err error) {
    if len(args) < 2 {
        // port not specified
        return -1, -1, nil
    } else if count := strings.Count(args[1], ":"); count == 0 {

Function NewForwardCommand has 6 return statements (exceeds 4 allowed).

Open

func NewForwardCommand() *cobra.Command {
    cmd := &cobra.Command{
        Use:   "forward",
        Short: "Redirect local port to a service or any remote address",
        PreRunE: func(cmd *cobra.Command, args []string) error {

Function GetServiceByResourceName has 6 return statements (exceeds 4 allowed).

Open

func GetServiceByResourceName(resourceName, namespace string) (*coreV1.Service, error) {
    resourceType, name, err := ParseResourceName(resourceName)
    if err != nil {
        return nil, err
    }

Function GetDeploymentByResourceName has 6 return statements (exceeds 4 allowed).

Open

func GetDeploymentByResourceName(resourceName, namespace string) (*appV1.Deployment, error) {
    resourceType, name, err := ParseResourceName(resourceName)
    if err != nil {
        return nil, err
    }

Function createRouter has 5 arguments (exceeds 4 allowed). Consider refactoring.

Open

func createRouter(routerPodName string, svcName string, ports map[int]int, labels map[string]string, versionMark string) error {

Function Forward has 5 return statements (exceeds 4 allowed).

Open

func Forward(args []string) error {
    ch, err := general.SetupProcess(util.ComponentForward)
    if err != nil {
        return err
    }

Method Kubernetes.GetKtResources has 5 return statements (exceeds 4 allowed).

Open

func (k *Kubernetes) GetKtResources(namespace string) ([]coreV1.Pod, []coreV1.ConfigMap, []appV1.Deployment, []coreV1.Service, error) {
    pods, err := Ins().GetPodsByLabel(map[string]string{util.ControlBy: util.KubernetesToolkit}, namespace)
    if err != nil {
        return nil, nil, nil, nil, err
    }

Function NewRecoverCommand has 5 return statements (exceeds 4 allowed).

Open

func NewRecoverCommand() *cobra.Command {
    cmd := &cobra.Command{
        Use:  "recover",
        Short: "Restore traffic of specified kubernetes service changed by exchange or mesh",
        PreRunE: func(cmd *cobra.Command, args []string) error {

Method Kubernetes.createAndGetPod has 5 return statements (exceeds 4 allowed).

Open

func (k *Kubernetes) createAndGetPod(metaAndSpec *PodMetaAndSpec, sshcm string) (*coreV1.Pod, error) {
    if opt.Get().Global.UseShadowDeployment {
        if err := k.createShadowDeployment(metaAndSpec, sshcm); err != nil {
            return nil, err
        }

Function NewMeshCommand has 5 return statements (exceeds 4 allowed).

Open

func NewMeshCommand() *cobra.Command {
    cmd := &cobra.Command{
        Use:  "mesh",
        Short: "Redirect marked requests of specified kubernetes service to local",
        PreRunE: func(cmd *cobra.Command, args []string) error {

Function NewConnectCommand has 5 return statements (exceeds 4 allowed).

Open

func NewConnectCommand() *cobra.Command {
    cmd := &cobra.Command{
        Use:  "connect",
        Short: "Create a network tunnel to kubernetes cluster",
        PreRunE: func(cmd *cobra.Command, args []string) error {