快速上手deployment模块开发

package main
import (
 "context"
 "fmt"
 "time"
 metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
 "k8s.io/client-go/kubernetes"
 "k8s.io/client-go/tools/clientcmd"
)
func main() {
 // 使用 kubeconfig 文件创建客户端
 config, err := clientcmd.BuildConfigFromFlags("", "/path/to/kubeconfig")
 if err != nil {
 panic(err)
 }
 clientset, err := kubernetes.NewForConfig(config)
 if err != nil {
 panic(err)
 }
 // 获取 Deployment 列表
 deployments, err := clientset.AppsV1().Deployments("default").List(context.TODO(), metav1.ListOptions{})
 if err != nil {
 panic(err)
 }
 fmt.Printf("Deployments: %v\n", deployments.Items)
 // 获取指定 Deployment 
 deployment, err := clientset.AppsV1().Deployments("default").Get(context.TODO(), "nginx-deployment", metav1.GetOptions{})
 if err != nil {
 panic(err)
 }
 fmt.Printf("Deployment: %v\n", deployment)
 // 监听 Deployment 的 rollout 状态
  watch, err := clientset.AppsV1().Deployments("default").Watch(context.TODO(), metav1.ListOptions{
 FieldSelector: "metadata.name=nginx-deployment"})
 if err != nil {
 panic(err)
 }
 // 事件循环
 for event := range watch.ResultChan() {
 deployment = event.Object.(*v1.Deployment)
 fmt.Printf("Deployment: %s, Status: %v\n", deployment.Name, deployment.Status.Conditions[0].Status)
 // 成功部署后停止监听
 if deployment.Status.Conditions[0].Status == "True" && 
  deployment.Status.Conditions[0].Reason == "NewReplicaSetAvailable" {
 watch.Stop()
 }
 }
}

package main
import (
 "context"
 "fmt"
 metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
 "k8s.io/client-go/kubernetes"
 "k8s.io/client-go/tools/clientcmd"
)
func main() {
 // 使用 kubeconfig 文件创建客户端
 config, err := clientcmd.BuildConfigFromFlags("", "/path/to/kubeconfig")
 if err != nil {
 panic(err)
 }
 clientset, err := kubernetes.NewForConfig(config)
 if err != nil {
 panic(err)
 }
 // 获取 Deployment 列表
 deployments, err := clientset.AppsV1().Deployments("").List(context.TODO(), metav1.ListOptions{})
 if err != nil {
 panic(err)
 }
 // 遍历并打印每个 Deployment 的详情
 for _, d := range deployments.Items {
 // Deployment 详细信息
 fmt.Printf("Name:%s\n", d.Name)
 fmt.Printf("Namespace:%s\n", d.Namespace)
 fmt.Printf("CreationTimestamp:%s\n", d.CreationTimestamp)
 fmt.Printf("Labels:%v\n", d.Labels)
 // Status 信息
 status := d.Status
 fmt.Printf("AvailableReplicas:%d\n", status.AvailableReplicas)
 fmt.Printf("ReadyReplicas:%d\n", status.ReadyReplicas)
 fmt.Printf("UpdatedReplicas:%d\n", status.UpdatedReplicas)
 fmt.Println() }
}

Name:coredns
Namespace:kube-system
CreationTimestamp:2022-07-16 16:21:28 +0800 CST
Labels:map[k8s-app:kube-dns]
AvailableReplicas:2
ReadyReplicas:2
 UpdatedReplicas:2

├── api    // API 接口目录        
│  ├── v1             
│  │   ├── node.go    
│  │   ├── pod.go
│  │   └── ...
│  └── v2
├── config          
│  ├── config.go    // 全局配置结构体和读取配置函数
│  └── config.yaml // 配置文件
├── controllers       // controller层 
│  ├── node_controller.go
│   ├── pod_controller.go
│  └── ...
├── dao           // 数据访问层目录   
│  ├── node_dao.go  
│  ├── pod_dao.go
│  └── ...
├── docs            
├── logs
├── models          // 模型层目录
│  ├── node.go      
│  ├── pod.go  
│  └── ...
├── routers         // 路由目录
│  └── router.go    
├── services        // 服务层目录
│  ├── node_service.go
│  ├── pod_service.go
│  └── ... 
└── utils             // 工具函数目录
├── consts.go   
├── jwt.go      
└── ...

1. API:对外提供 v1 和 v2 两个 API 版本接口。
2. Config:配置文件读取。
3. Controllers:请求参数获取,调用服务层,返回响应。
4. Services:核心业务逻辑。
5. DAO:数据访问层。
6. Models:数据模型。
7. Utils:工具函数等。
8. Routers:API 路由注册。
9. Docs:OpenAPI 文档。
10. Logs:日志目录。

go
import "fmt"
import "os"
import "strings"