INNER CODE UNIT · Go

MustNewKubeTunnel

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

func MustNewKubeTunnel(kubeConfig string, namespace string, privileged bool) *KubeTunnel {

	if len(kubeConfig) > 0 {
		_ = os.Setenv("KUBECONFIG", kubeConfig) // Workaround for internal client created by kubefwd
	}

	kubeClient := kube.MustNew(kubeConfig, namespace)

	err := kubeClient.ConnectivityCheck()
	if err != nil {
		log.Panicf(err.Error())
	}

	err = kubeClient.RBACCheck()
	if err != nil {
		log.Panicf(err.Error())
	}

View source record →