|
|
package ClientSet
|
|
|
|
|
|
import (
|
|
|
"ClientGo/utils"
|
|
|
"context"
|
|
|
"fmt"
|
|
|
v1 "k8s.io/api/core/v1"
|
|
|
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
|
|
|
"k8s.io/client-go/kubernetes"
|
|
|
"log"
|
|
|
"reflect"
|
|
|
)
|
|
|
|
|
|
/**
|
|
|
@author: sre
|
|
|
@date: 2022/8/10 0010
|
|
|
@desc: RESTClient虽然可以操作 Kubernetes 的所有资源对象，但是使用起来确实比较复杂，需要配置的参数过于繁琐，因此，为了更优雅的更方便的与 Kubernetes APIServer 进行交互，则需要进一步的封装。
|
|
|
前面有过介绍，ClientSet 是基于 RESTClient 的封装，同时 ClientSet 是使用预生成的 API 对象与 APIServer 进行交互的，这样做更方便进行二次开发。
|
|
|
ClientSet 是一组资源对象客户端的集合，例如负责操作 Pods、Services 等资源的 CoreV1Client，负责操作 Deployments、DaemonSets 等资源的 AppsV1Client 等。通过这些资源对象客户端提供的操作方法，即可对 Kubernetes 内置的资源对象进行 Create、Update、Get、List、Delete 等操作。
|
|
|
**/
|
|
|
|
|
|
// GetClientSet ClientSet 是一组资源对象客户端的集合，例如负责操作 Pods、Services 等资源的 CoreV1Client，负责操作 Deployments、DaemonSets 等资源的 AppsV1Client 等。
|
|
|
// 通过这些资源对象客户端提供的操作方法，即可对 Kubernetes 内置的资源对象进行 Create、Update、Get、List、Delete 等操作。
|
|
|
|
|
|
func GetClientSet() (*kubernetes.Clientset, error) {
|
|
|
config, err := utils.GetConfig()
|
|
|
if err != nil {
|
|
|
log.Println("GetConfig 失败: ", err.Error())
|
|
|
return nil, err
|
|
|
}
|
|
|
|
|
|
// 实例化 ClientSet
|
|
|
clientset, err := kubernetes.NewForConfig(config)
|
|
|
if err != nil {
|
|
|
log.Println("实例化 ClientSet 失败: ", err.Error())
|
|
|
return nil, err
|
|
|
}
|
|
|
return clientset, nil
|
|
|
|
|
|
}
|
|
|
|
|
|
// ListCms 列出所有的 ConfigMap
|
|
|
func ListCms(namespace string) (*v1.ConfigMapList, error) {
|
|
|
clientSet, err := GetClientSet()
|
|
|
if err != nil {
|
|
|
log.Println("GetClientSet 失败: ", err.Error())
|
|
|
return nil, err
|
|
|
}
|
|
|
|
|
|
configMaps, err := clientSet.CoreV1().ConfigMaps(namespace).List(context.TODO(), metav1.ListOptions{})
|
|
|
if err != nil {
|
|
|
return nil, err
|
|
|
}
|
|
|
return configMaps, err
|
|
|
//for _, cm := range configMaps.Items {
|
|
|
// fmt.Printf("configName: %v, configData: %v \n", cm.Name, cm.Data)
|
|
|
//}
|
|
|
//return nil
|
|
|
}
|
|
|
|
|
|
func ListNodes() (*v1.NodeList, error) {
|
|
|
clientSet, err := GetClientSet()
|
|
|
if err != nil {
|
|
|
log.Println("GetClientSet 失败: ", err.Error())
|
|
|
return nil, err
|
|
|
}
|
|
|
|
|
|
nodeList, err := clientSet.CoreV1().Nodes().List(context.TODO(), metav1.ListOptions{})
|
|
|
if err != nil {
|
|
|
return nil, err
|
|
|
}
|
|
|
return nodeList, err
|
|
|
//for _, node := range nodeList.Items {
|
|
|
// fmt.Printf("nodeName: %v, status: %v", node.GetName(), node.GetCreationTimestamp())
|
|
|
//}
|
|
|
//return nil
|
|
|
}
|
|
|
|
|
|
func ListPods(namespace string) (*v1.PodList, error) {
|
|
|
clientSet, err := GetClientSet()
|
|
|
if err != nil {
|
|
|
log.Println("GetClientSet 失败: ", err.Error())
|
|
|
return nil, err
|
|
|
}
|
|
|
pods, err := clientSet.CoreV1().Pods(namespace).List(context.TODO(), metav1.ListOptions{})
|
|
|
if err != nil {
|
|
|
return nil, err
|
|
|
}
|
|
|
return pods, nil
|
|
|
//for _, v := range pods.Items {
|
|
|
// fmt.Printf("namespace: %v podname: %v podstatus: %v \n", v.Namespace, v.Name, v.Status.Phase)
|
|
|
//}
|
|
|
}
|
|
|
|
|
|
func ListDeployment(namespace string) error {
|
|
|
clientSet, err := GetClientSet()
|
|
|
if err != nil {
|
|
|
log.Println("GetClientSet 失败: ", err.Error())
|
|
|
return err
|
|
|
}
|
|
|
deployments, err := clientSet.AppsV1().Deployments(namespace).List(context.TODO(), metav1.ListOptions{})
|
|
|
if err != nil {
|
|
|
return err
|
|
|
}
|
|
|
fmt.Println(reflect.TypeOf(deployments))
|
|
|
for index, deployment := range deployments.Items {
|
|
|
//fmt.Println(reflect.TypeOf(deployment))
|
|
|
fmt.Printf("deployment %v: %v \n", index, deployment)
|
|
|
}
|
|
|
|
|
|
//fmt.Println("deployments: ", deployments)
|
|
|
|
|
|
//for _, v := range deployments.Items {
|
|
|
// fmt.Printf("deploymentname: %v, available: %v, ready: %v", v.GetName(), v.Status.AvailableReplicas, v.Status.ReadyReplicas)
|
|
|
//}
|
|
|
return nil
|
|
|
}
|
