client-go調用kubernetes API實例

package  main

import (
   "flag"
   "k8s.io/client-go/kubernetes"
   "k8s.io/client-go/tools/clientcmd"
   apiv1 "k8s.io/api/core/v1"
   metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
   //v1beta1 "k8s.io/api/apps/v1beta1"
   //dly "k8s.io/client-go/kubernetes/typed/apps/v1beta1"
   "fmt"
)

func main() {
   kubeconfig := flag.String("kubeconfig","","absolute path to the kubeconfig file")　　///這里是使用用戶名和密碼調用APIserver，所以kubeconfig為空
   flag.Parse()
   config, err := clientcmd.BuildConfigFromFlags("https://kubernetes-master-ip:6443",*kubeconfig)    
   config.Insecure = true
   
   //APIserver的用戶名和密碼
   config.Username = "admin"                     
   config.Password = "admin"
   if err != nil {
      panic(err.Error())
   }

   // create the clientset
   clientset, err := kubernetes.NewForConfig(config)
   if err != nil {
      panic(err.Error())
   }

   //創建命名空間//
   a := createns(clientset,"client-go")
   if a != 0 {
      fmt.Println("The namespace  create  is ok!")
   }else {
      fmt.Println("The namespace  create  is failed!")
   }

}


//創建命令空間函數//
func createns (clientsetx *kubernetes.Clientset, nsname string) int  {
   nc := new(apiv1.Namespace)
   nc.TypeMeta = metav1.TypeMeta{Kind:"Namespace",APIVersion:"v1"}
   nc.ObjectMeta = metav1.ObjectMeta{
      Name: nsname,
   }
   nc.Spec = apiv1.NamespaceSpec{}
   _ ,err := clientsetx.CoreV1().Namespaces().Create(nc)
   if err != nil {
      return  0
   } else {
      return 1
   }
}