Function main has 70 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func main() {
    // git describe --tags `git rev-list --tags --max-count=1`
    commitId, err2 := exec.Command("git", "rev-list", "--tags", "--max-count=1").Output()
    if err2 != nil {
        panic(err2)

Function ConvertK8sApiServerToDomain has 69 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func ConvertK8sApiServerToDomain(kubeConfigPath string) (newPath string, err error) {
    var kubeConfigBytes []byte
    kubeConfigBytes, err = os.ReadFile(kubeConfigPath)
    if err != nil {
        return

Function init has 69 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func init() {
    http.Handle("/ws", websocket.Handler(func(conn *websocket.Conn) {
        var sshConfig pkgssh.SshConfig
        b := conn.Request().Header.Get("ssh")
        if err := json.Unmarshal([]byte(b), &sshConfig); err != nil {

Method CloneOptions.SyncDir has a Cognitive Complexity of 29 (exceeds 20 allowed). Consider refactoring.

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
    }

• Read up
  Read up

Method Manager.RentIP has a Cognitive Complexity of 29 (exceeds 20 allowed). Consider refactoring.

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 {

• Read up
  Read up

Function CmdDisconnect has 68 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func CmdDisconnect(f cmdutil.Factory) *cobra.Command {
    var all = false
    var clusterIDs []string
    cmd := &cobra.Command{
        Use:   "disconnect",

Function InjectVPNSidecar has 68 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func InjectVPNSidecar(ctx1 context.Context, factory util.Factory, namespace, workload string, c util2.PodRouteConfig) error {
    object, err := util2.GetUnstructuredObject(factory, namespace, workload)
    if err != nil {
        return err
    }

Method Server.Get has 68 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func (svr *Server) Get(ctx context.Context, req *rpc.GetRequest) (*rpc.GetResponse, error) {
    if svr.connect == nil || svr.connect.Context() == nil {
        return nil, errors.New("not connected")
    }
    if svr.resourceLists == nil {

Function NewStack has 68 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func NewStack(ctx context.Context, tun stack.LinkEndpoint) *stack.Stack {
    s := stack.New(stack.Options{
        NetworkProtocols: []stack.NetworkProtocolFactory{
            ipv4.NewProtocol,
            ipv6.NewProtocol,

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

Open

func (c *fakeUDPTunnelConnector) ConnectContext(ctx context.Context, conn net.Conn) (net.Conn, error) {
    //defer conn.SetDeadline(time.Time{})
    switch con := conn.(type) {
    case *net.TCPConn:
        err := con.SetNoDelay(true)

• Read up
  Read up

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

Open

func (c *gvisorUDPOverTCPTunnelConnector) ConnectContext(ctx context.Context, conn net.Conn) (net.Conn, error) {
    switch con := conn.(type) {
    case *net.TCPConn:
        err := con.SetNoDelay(true)
        if err != nil {

• Read up
  Read up

Method PortForwarder.handleConnection has 67 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func (pf *PortForwarder) handleConnection(conn net.Conn, port ForwardedPort) {
    defer conn.Close()

    if pf.out != nil {
        fmt.Fprintf(pf.out, "Handling connection for %d\n", port.Local)

Method SvrOption.Start has 67 lines of code (exceeds 50 allowed). Consider refactoring.

Open

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

Function createTun has 67 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func createTun(cfg Config) (conn net.Conn, itf *net.Interface, err error) {
    if cfg.Addr == "" && cfg.Addr6 == "" {
        err = fmt.Errorf("IPv4 address and IPv6 address can not be empty at same time")
        return
    }

Function gen has 67 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func gen(connect *handler.ConnectOptions, clone *handler.CloneOptions) ([]*rpc.Proxy, []*rpc.Clone, error) {
    var proxyList []*rpc.Proxy
    if connect != nil && connect.GetClientset() != nil {
        mapInterface := connect.GetClientset().CoreV1().ConfigMaps(connect.Namespace)
        configMap, err := mapInterface.Get(context.Background(), config.ConfigMapPodTrafficManager, metav1.GetOptions{})

Method ConnectOptions.DoConnect has 66 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func (c *ConnectOptions) DoConnect(ctx context.Context, isLite bool) (err error) {
    c.ctx, c.cancel = context.WithCancel(ctx)

    log.Info("Starting connect")
    m := dhcp.NewDHCPManager(c.clientset.CoreV1().ConfigMaps(c.Namespace), c.Namespace)

Function CmdAlias has 66 lines of code (exceeds 50 allowed). Consider refactoring.

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.setupDNS has 66 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func (c *ConnectOptions) setupDNS(ctx context.Context) error {
    const port = 53
    const portTCP = 10800
    pod, err := c.GetRunningPodList(ctx)
    if err != nil {

Method wsHandler.installKubevpnOnRemote has 66 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func (w *wsHandler) installKubevpnOnRemote(ctx context.Context, sshClient *ssh.Client) (err error) {
    defer func() {
        if err == nil {
            w.Log("Remote daemon server version: %s", startDaemonProcess(sshClient))
        }

Method Krb5InitiatorClient.InitSecContext has 66 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func (k *Krb5InitiatorClient) InitSecContext(target string, token []byte, isGSSDelegCreds bool) ([]byte, bool, error) {
    GSSAPIFlags := []int{
        ContextFlagREADY,
        gssapi.ContextFlagInteg,
        gssapi.ContextFlagMutual,