INNER CODE UNIT · Go

func

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

func (ct *KubeTunnel) Install(operatorVersion string) {

	err := ct.helmClient.InstallKubeTunnelOperator(operatorVersion)
	if err != nil {
		log.Panic(err.Error())
	}
}

func (ct *KubeTunnel) CreateTunnel(tunnelConf KubeTunnelConf) {

	svcCtx, err := ct.kubeClient.GetServiceContext(tunnelConf.ServiceName)
	if err != nil {
		log.Panic(err.Error())
	}

	labels, err := ct.kubeClient.GetPodLabelsByLabelSelector(ct.kubeClient.Namespace, svcCtx.LabelSelector)
	if err != nil {
		log.Panic(err.Error())

View source record →