Avoid deeply nested control flow statements.

Open

                    } else if err != nil {
                        return err
                    }

Method CloneOptions.SyncDir has 7 return statements (exceeds 4 allowed).

Open

func (d *CloneOptions) SyncDir(ctx context.Context, labels string) error {
    list, err := util.GetRunningPodList(ctx, d.targetClientset, d.TargetNamespace, labels)
    if err != nil {
        return err
    }

Function NewOnAddresses has 6 arguments (exceeds 4 allowed). Consider refactoring.

Open

func NewOnAddresses(dialer httpstream.Dialer, addresses []string, ports []string, stopChan <-chan struct{}, readyChan chan struct{}, out, errOut io.Writer) (*PortForwarder, error) {

Method SvrOption.Start has 7 return statements (exceeds 4 allowed).

Open

func (o *SvrOption) Start(ctx context.Context) error {
    l := &lumberjack.Logger{
        Filename:   action.GetDaemonLogPath(),
        MaxSize:    100,
        MaxAge:     3,

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

Open

func TransferImage(ctx context.Context, conf *SshConfig, imageSource, imageTarget string, out io.Writer) error {
    client, cli, err := GetClient()
    if err != nil {
        log.Errorf("Failed to get docker client: %v", err)
        return err

• Read up
  Read up

Avoid deeply nested control flow statements.

Open

        if config.Keyfile == "" {
            config.Keyfile = filepath.Join(homedir.HomeDir(), ".ssh", "id_rsa")
        }

Method CopyOptions.Run has 7 return statements (exceeds 4 allowed).

Open

func (o *CopyOptions) Run() error {
    srcSpec, err := extractFileSpec(o.args[0])
    if err != nil {
        return err
    }

Avoid deeply nested control flow statements.

Open

        if err != nil {
            return nil, err
        }

Avoid deeply nested control flow statements.

Open

                } else if lookup.DefValue != "" {
                    configFlags.KubeConfig = pointer.String(lookup.DefValue)
                }

Avoid deeply nested control flow statements.

Open

        } else if code := status.Code(err); code == codes.AlreadyExists {
            return fmt.Errorf("connect with cluster already established, disconnect required before proceeding")
        } else {
            return err
        }

Method Manager.RentIP has 7 return statements (exceeds 4 allowed).

Open

func (m *Manager) RentIP(ctx context.Context) (*net.IPNet, *net.IPNet, error) {
    addrs, _ := net.InterfaceAddrs()
    var isAlreadyExistedFunc = func(ip net.IP) bool {
        for _, addr := range addrs {
            if addr == nil {

Function PullImage has 6 arguments (exceeds 4 allowed). Consider refactoring.

Open

func PullImage(ctx context.Context, platform *v1.Platform, cli *client.Client, dockerCli *command.DockerCli, img string, out io.Writer) error {

Avoid deeply nested control flow statements.

Open

                } else if err != nil {
                    log.Errorf("Receive from disconnect failed: %v", err)
                    return err
                }

Avoid deeply nested control flow statements.

Open

        if err != nil {
            return nil, err
        }

Avoid deeply nested control flow statements.

Open

                } else if lookup.DefValue != "" {
                    path = lookup.DefValue
                } else {
                    path = lookup.NoOptDefVal
                }

Avoid deeply nested control flow statements.

Open

            } else if event.Op&fsnotify.Remove == fsnotify.Remove {
                notifyCh <- NotifyMessage{
                    Operation: Remove,
                    FilePath:  event.Name,
                }

Method CCache.writePrincipal has 7 return statements (exceeds 4 allowed).

Open

func (c *CCache) writePrincipal(p principal, endian *binary.ByteOrder) ([]byte, error) {
    var byteString bytes.Buffer
    var err error

    b := &byteString

Function NewTunEndpoint has 6 arguments (exceeds 4 allowed). Consider refactoring.

Open

func NewTunEndpoint(ctx context.Context, tun net.Conn, mtu uint32, engine config.Engine, in chan<- *DataElem, out chan *DataElem) stack.LinkEndpoint {

Method hijackedIOStreamer.stream has 7 return statements (exceeds 4 allowed).

Open

func (h *hijackedIOStreamer) stream(ctx context.Context) error {
    restoreInput, err := h.setupInput()
    if err != nil {
        return fmt.Errorf("unable to setup input stream: %s", err)
    }

Avoid deeply nested control flow statements.

Open

                        if net.ParseIP(svc.Spec.ClusterIP) == nil {
                            continue
                        }