INNER CODE UNIT · Go

kube

we-dcode/kubetunnel · cmd/operator/main.go:199

	kube := connectToKubernetes(req.Namespace) // TODO: change this one
	isConnected, err := strconv.ParseBool(req.IsConnected)
	if err != nil {
		fmt.Errorf(err.Error())
	}
	error := patchServiceWithLabel(kube, req.Name, isConnected)
	if error != nil {
		fmt.Errorf("error %v", err)
	} else {
		fmt.Print("No error!")
	}

}

func connectToKubernetes(namespace string) *kube.Kube {

	kubeClient := kube.MustNew("", namespace)

View source record →