INNER CODE UNIT · Go

err

we-dcode/kubetunnel · pkg/kubetunnel.go:97

	err = <-kubefwdSyncChannel

	if err != nil {
		log.Panicf("fail executing kubefwd: %s", err.Error())
	}

	log.Info("executing frpc")

	common := frpmodels.Common{
		ServerAddress: fmt.Sprintf("%s-%s", constants.KubetunnelSlug, kubeTunnelResourceSpec.ServiceName),
		ServerPort:    constants.FRPServerPort,
	}

	servicePortsPairs := servicecontext.ToFRPClientPairs(tunnelConf.LocalIP, tunnelConf.KubeTunnelPortMap, svcCtx)

	frpcManager := frpc.NewManager(common, servicePortsPairs, hostFile)

	frpcManager.RunFRPc()

View source record →