安装go client调用Kubernetes API
虽然Kubernetes是用go语言编写的，但是安装go client比安装python client复杂很多。python只需要在PyCharm中安装一个kubernetes包即可，而go则需要很复杂的一系列步骤。
主要按照https://github.com/kubernetes/client-go/blob/master/INSTALL.md的操作进行。默认已经正确安装了go并且正确配置了GOPATH。
最好保证电脑能顺畅地连接外网，否则有些包下载会特别慢。
一、下载go-client包
$ go get -u -v k8s.io/client-go/...
因为不能科学上网，这一步我足足等待了一个小时。为了确认下载的确在进行，加上了-u和-v，可以看见具体下载的过程。
下载完成后，对照官方GitHub中go-client和执行下面的操作：
$ cd $GOPATH/src/k8s.io/client-go $ git checkout v9.0.0 #这里要根据版本对照表，找出和自己的Kubernetes集群对应的版本
注意：我测试时使用v7.0.0以下的版本时出现了依赖包不匹配的问题，导致编译错误。换成v8.0.0就正常了。所以：
尽量使用v8.0.0以上的版本！尽量使用v8.0.0以上的版本！尽量使用v8.0.0以上的版本！
二、安装godep
$ go get github.com/tools/godep
三、使用godep下载依赖包
godep是golang中管理依赖包的工具。在GOPATH/src/k8s.io/client-go目录下执行下面的命令后，godep会从Godeps/Godeps.json文件中下载依赖包并安装：
$ godep restore ./...
这一步同样等待了很长很长时间，耐心很重要。。。。。。
四、手动下载报错的包
执行godep restore时，会出现诸如：godep: error downloading dep (cloud.google.com/go/internal): unrecognized import path "cloud.google.com/go/internal"之类的错误，这是由于下载包的url路径与import的路径不一致，导致下载失败。这时只能手动下载报错的包。
网上搜索报错的包的url位置，用git clone命令下载。
cloud.google.com/go的位置在https://github.com/GoogleCloudPlatform/google-cloud-go。在$GOPATH/src下创建cloud.google.com目录后，在新目录下执行：
$ git clone https://github.com/GoogleCloudPlatform/google-cloud-go
之后，把google-cloud-go文件夹重命名为go。
golang.org/x/下的包都位于 https://github.com/golang/下。在$GOPATH/src下创建golang.org/x/目录后，针对所有golang.org/x/下报错的包，在新目录下依次执行：
$ git clone https://github.com/golang/xxx.git xxx #xxx为报错的包
下载完所有的包后，可以用Goland尝试import一下报错的目录，看看是否能够正常导入。
五、运行测试代码
创建一个工程，编写main.go如下：
package main
import (
"flag"
"fmt"
"os"
"path/filepath"
"time"
"k8s.io/apimachinery/pkg/api/errors"
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
"k8s.io/client-go/kubernetes"
"k8s.io/client-go/tools/clientcmd"
)
func main() {
var kubeconfig *string
if home := homeDir(); home != "" {
kubeconfig = flag.String("kubeconfig", filepath.Join(home, "src", "go-kubernetes", "config"), "(optional) absolute path to the kubeconfig file")
} else {
kubeconfig = flag.String("kubeconfig", "", "absolute path to the kubeconfig file")
}
flag.Parse()
// use the current context in kubeconfig
config, err := clientcmd.BuildConfigFromFlags("", *kubeconfig)
if err != nil {
panic(err.Error())
}
// create the clientset
clientset, err := kubernetes.NewForConfig(config)
if err != nil {
panic(err.Error())
}
for {
pods, err := clientset.CoreV1().Pods("default").List(metav1.ListOptions{})
if err != nil {
panic(err.Error())
}
fmt.Printf("There are %d pods in the cluster\n", len(pods.Items))
// Examples for error handling:
// - Use helper functions like e.g. errors.IsNotFound()
// - And/or cast to StatusError and use its properties like e.g. ErrStatus.Message
namespace := ""
pod := "example-xxxxx"
_, err = clientset.CoreV1().Pods(namespace).Get(pod, metav1.GetOptions{})
if errors.IsNotFound(err) {
fmt.Printf("Pod %s in namespace %s not found\n", pod, namespace)
} else if statusError, isStatus := err.(*errors.StatusError); isStatus {
fmt.Printf("Error getting pod %s in namespace %s: %v\n",
pod, namespace, statusError.ErrStatus.Message)
} else if err != nil {
panic(err.Error())
} else {
fmt.Printf("Found pod %s in namespace %s\n", pod, namespace)
}
time.Sleep(10 * time.Second)
}
}
func homeDir() string {
if h := os.Getenv("GOPATH"); h != "" {
return h
}
return os.Getenv("USERPROFILE")
}
首先在集群中任意节点的~/.kube目录下找到config文件，将config文件拷贝到go运行的机器上，具体目录可以通过自定义的homeDir函数和flag.String指定，我这里设置在工程的根目录下。
运行程序，如果能正确显示出pod的数量，说明配置成功！
最后，个人感觉go的client真心不如python的client好用。且不说安装的复杂程度，client-go是没有官方文档的，对新手极不友好，而python client的文档非常详细，简单易用。
此外，python的yaml包支持用load方法将写好的yaml文件直接读入并解析，而go的yaml包则相对复杂，这导致在golang中通过yaml文件操作Kubernetes资源远比python中麻烦。一种可行的操作是将yaml文件的各个字段直接编码到代码中，通过dynamic、unstructure等包进行解析，比直接修改yaml文件更加灵活。