kubenetworks/kubevpn

Identical blocks of code found in 2 locations. Consider refactoring.

Open

            for {
                resp, err = client.Recv()
                if err == io.EOF {
                    break
                } else if err == nil {

• Read up
  Read up

Similar blocks of code found in 2 locations. Consider refactoring.

Open

func GvisorTCPListener(addr string) (net.Listener, error) {
    log.Debugf("Gvisor tcp listen addr %s", addr)
    laddr, err := net.ResolveTCPAddr("tcp", addr)
    if err != nil {
        return nil, err

• Read up
  Read up

Similar blocks of code found in 2 locations. Consider refactoring.

Open

    if cfg.Addr != "" {
        if ipv4, _, err = net.ParseCIDR(cfg.Addr); err != nil {
            return
        }
        var prefix netip.Prefix

• Read up
  Read up

Similar blocks of code found in 2 locations. Consider refactoring.

Open

    if cfg.Addr6 != "" {
        if ipv6, _, err = net.ParseCIDR(cfg.Addr6); err != nil {
            return
        }
        var prefix netip.Prefix

• Read up
  Read up

Similar blocks of code found in 2 locations. Consider refactoring.

Open

func GvisorUDPListener(addr string) (net.Listener, error) {
    log.Debugf("Gvisor UDP over TCP listen addr %s", addr)
    laddr, err := net.ResolveTCPAddr("tcp", addr)
    if err != nil {
        return nil, err

• Read up
  Read up

Identical blocks of code found in 2 locations. Consider refactoring.

Open

    do := f.NewBuilder().
        Unstructured().
        NamespaceParam(ns).DefaultNamespace().AllNamespaces(false).
        ResourceTypeOrNameArgs(true, workloads...).
        ContinueOnError().

• Read up
  Read up

Identical blocks of code found in 2 locations. Consider refactoring.

Open

    do := f.NewBuilder().
        Unstructured().
        NamespaceParam(ns).DefaultNamespace().AllNamespaces(false).
        ResourceTypeOrNameArgs(true, workloads).
        ContinueOnError().

• Read up
  Read up

Method CloneOptions.InitClient has 6 return statements (exceeds 4 allowed).

Open

func (d *CloneOptions) InitClient(f cmdutil.Factory) (err error) {
    d.factory = f
    if d.config, err = d.factory.ToRESTConfig(); err != nil {
        return
    }

Method CloneOptions.setVolume has 6 return statements (exceeds 4 allowed).

Open

func (d *CloneOptions) setVolume(u *unstructured.Unstructured) error {

    const TokenVolumeMountPath = "/var/run/secrets/kubernetes.io/serviceaccount"

    type VolumeMountContainerPair struct {

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

Open

func GetManifest(httpCli *http.Client, os string, arch string) (version string, url string, err error) {
    var resp *http.Response
    var errs []error
    for _, a := range address {
        resp, err = httpCli.Get(a)

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

Open

func CmdRemove(f cmdutil.Factory) *cobra.Command {
    var cmd = &cobra.Command{
        Use:   "remove",
        Short: "Remove clone resource",
        Long: templates.LongDesc(i18n.T(`

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

Open

func UnzipKubeVPNIntoFile(zipFile, filename string) error {
    archive, err := zip.OpenReader(zipFile)
    if err != nil {
        return err
    }

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

Open

func CmdDaemon(_ cmdutil.Factory) *cobra.Command {
    var opt = &daemon.SvrOption{}
    cmd := &cobra.Command{
        Use:   "daemon",
        Short: i18n.T("Startup kubevpn daemon server"),

Method ConnectOptions.portForward has 6 return statements (exceeds 4 allowed).

Open

func (c *ConnectOptions) portForward(ctx context.Context, portPair []string) error {
    firstCtx, firstCancelFunc := context.WithCancel(ctx)
    defer firstCancelFunc()
    var errChan = make(chan error, 1)
    go func() {

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

Open

func CmdLeave(f cmdutil.Factory) *cobra.Command {
    var leaveCmd = &cobra.Command{
        Use:   "leave",
        Short: i18n.T("Leave proxy resource"),
        Long: templates.LongDesc(i18n.T(`

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

Open

func CmdLogs(f cmdutil.Factory) *cobra.Command {
    req := &rpc.LogRequest{}
    cmd := &cobra.Command{
        Use:   "logs",
        Short: i18n.T("Log kubevpn daemon grpc server"),

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

Open

func DownloadFileWithName(uri, name string) (string, error) {
    resp, err := getWithRetry(uri)
    if err != nil {
        return "", err
    }

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

Open

func CmdAlias(f cmdutil.Factory) *cobra.Command {
    var localFile, remoteAddr string
    cmd := &cobra.Command{
        Use:   "alias",
        Short: i18n.T("Config file alias to execute command simply"),

Method ConnectOptions.GetIPFromContext has 6 return statements (exceeds 4 allowed).

Open

func (c *ConnectOptions) GetIPFromContext(ctx context.Context) error {
    md, ok := metadata.FromIncomingContext(ctx)
    if !ok {
        return fmt.Errorf("can not get IOP from context")
    }

Method ConnectOptions.startLocalTunServe has 6 return statements (exceeds 4 allowed).

Open

func (c *ConnectOptions) startLocalTunServe(ctx context.Context, forwardAddress string, lite bool) (err error) {
    log.Debugf("IPv4: %s, IPv6: %s", c.localTunIPv4.IP.String(), c.localTunIPv6.IP.String())

    var cidrList []*net.IPNet
    if !lite {