kube-client.go

package main

import (
	"crypto/tls"
	"encoding/json"
	"fmt"
	"io"
	"log"
	"net/http"
)

func GetServices() ServiceList {
	log.Println("Getting all services")
	response := request("api/v1/services", http.MethodGet, nil)
	defer response.Body.Close()
	var serviceList ServiceList
	if err := json.NewDecoder(response.Body).Decode(&serviceList); err != nil {
		log.Fatal(err)
	}
	return serviceList
}

func GetIngresses() IngressList {
	log.Println("Getting all ingresses")
	response := request("apis/extensions/v1beta1/ingresses", http.MethodGet, nil)
	defer response.Body.Close()
	var ingressList IngressList
	if err := json.NewDecoder(response.Body).Decode(&ingressList); err != nil {
		log.Fatal(err)
	}
	return ingressList
}

func request(path string, method string, data io.Reader) *http.Response {
	url := fmt.Sprintf("%s://%s:%s/%s", appConfig.Protocol, appConfig.KubeHost, appConfig.KubePort, path)
	client := http.Client{
		Transport: &http.Transport{
			TLSClientConfig: &tls.Config{InsecureSkipVerify: appConfig.SkipTlsVerify},
		},
	}
	request, err := http.NewRequest(method, url, data)
	if err != nil {
		log.Fatal(err)
	}
	authorizationToken := fmt.Sprintf("Bearer %s", appConfig.APIKey)
	request.Header.Set("Authorization", authorizationToken)
	response, respErr := client.Do(request)
	if respErr != nil {
		log.Fatal(respErr)
	}
	if response.StatusCode == 401 {
		log.Fatal("Cannot authorize to connect to Kubernetes API")
	}
	return response
}