INNER CODE UNIT · Go

connectToKubernetes

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

func connectToKubernetes(namespace string) *kube.Kube {

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

	err := kubeClient.ConnectivityCheck()
	if err != nil {
		fmt.Printf(err.Error())
	}

	return kubeClient
}

func patchServiceWithLabel(k *kube.Kube, serviceName string, connected bool) error {

	svcContext, err := k.GetServiceContext(serviceName)
	if err != nil {
		log.Errorf("fail to get service: '%s' context, error: %s", serviceName, err.Error())
	}

View source record →