Service模块开发

package main
import (
"context"
"fmt"
"time"
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
"k8s.io/client-go/kubernetes"
)
func main() {
// 创建Kubernetes客户端,使用InClusterConfig获取集群内部config
config, err := rest.InClusterConfig()
if err != nil {
panic(err.Error())
 }
clientset, err := kubernetes.NewForConfig(config)
if err != nil {
panic(err.Error())
 }
// 获取Namespace列表,使用ListOptions设置超时时间避免长时间等待
ctx, cancel := context.WithTimeout(context.Background(), 5*time.Second)
defer cancel()
namespaces, err := clientset.CoreV1().Namespaces().List(ctx,
metav1.ListOptions{})
if err != nil {
    panic(err.Error())
 }
// 遍历每个Namespace
for _, namespace := range namespaces.Items {
// 为每个Service创建context,单独设置超时时间
ctx, cancel := context.WithTimeout(context.Background(),
3*time.Second)   
defer cancel()


       // 获取Namespace下的Service列表
services, err := clientset.CoreV1().Services(namespace.Name).List(ctx,
metav1.ListOptions{})
if err != nil {
panic(err.Error())
}
 
// 遍历每个Service,获取详细信息
for _, service := range services.Items {
// 为获取Deployments创建context,设置超时时间     
ctx, cancel := context.WithTimeout(context.Background(),
3*time.Second)  
defer cancel()  
// 获取Service对应的Deployments
deployments, err :=
clientset.AppsV1().Deployments(namespace.Name).List(ctx,
metav1.ListOptions{LabelSelector: service.Spec.Selector})
if err != nil {
 panic(err.Error())
}
// 输出Service详细信息,增加相关注释
fmt.Printf("Name: %s\n", service.Name)       // Service名称
fmt.Printf("Namespace: %s\n", namespace.Name)   // 所在Namespace       
fmt.Printf("Label: %s\n", service.Labels)        // Service标签       
fmt.Printf("Selector: %s\n", service.Spec.Selector)   // Service选择器   
fmt.Printf("IP: %s\n", service.Spec.ClusterIP)     // 集群IP        
fmt.Printf("Port: %v\n", service.Spec.Ports)      // 端口信息      
fmt.Printf("Deployments: %s\n", deployments.Items)    // 关联的Deployments             
fmt.Println()  // 空行
}
 }
}

selector:
  app: myapp
  release: stable

"app=myapp,release=stable"

deployments, err := clientset.AppsV1().Deployments(namespace.Name).List(ctx,
metav1.ListOptions{LabelSelector: labels.Set(service.Spec.Selector).String()})
if err != nil {
panic(err.Error())
}

package main
import (
 "context"
 "github.com/gin-gonic/gin"
 metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
 "k8s.io/apimachinery/pkg/labels"
 "k8s.io/client-go/kubernetes"
 "k8s.io/client-go/tools/clientcmd"
 "k8s.io/client-go/util/homedir"
 "path/filepath"
)

router := gin.Default()

router.GET("/services", func(c
*gin.Context)

http://127.0.0.1:8080/services