【k8s多集群管理平台开发实践】client-go实现service读取列表、创建service、读取yaml配置并更新

在Kubernetes中，我们可以使用client-go库来与集群进行交互。以下是使用client-go读取服务列表、创建服务的代码示例。

1. 读取服务列表:

import (
    metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
    "k8s.io/client-go/kubernetes"
    "k8s.io/client-go/tools/clientcmd"
)
 
func ListServices(configPath, namespace string) (*v1.ServiceList, error) {
    // 使用kubeconfig文件创建配置
    config, err := clientcmd.BuildConfigFromFlags("", configPath)
    if err != nil {
        return nil, err
    }
 
    // 创建客户端
    clientset, err := kubernetes.NewForConfig(config)
    if err != nil {
        return nil, err
    }
 
    // 获取服务列表
    services, err := clientset.CoreV1().Services(namespace).List(context.TODO(), metav1.ListOptions{})
    if err != nil {
        return nil, err
    }
 
    return services, nil
}

2. 创建服务:

import (
    v1 "k8s.io/api/core/v1"
    metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
    "k8s.io/client-go/kubernetes"
    "k8s.io/client-go/tools/clientcmd"
)
 
func CreateService(configPath, namespace string, service *v1.Service) (*v1.Service, error) {
    // 使用kubeconfig文件创建配置
    config, err := clientcmd.BuildConfigFromFlags("", configPath)
    if err != nil {
        return nil, err
    }
 
    // 创建客户端
    clientset, err := kubernetes.NewForConfig(config)
    if err != nil {
        return nil, err
    }
 
    // 创建服务
    result, err := clientset.CoreV1().Services(namespace).Create(context.TODO(), service, metav1.CreateOptions{})
    if err != nil {
        return nil, err
    }
 
    return result, nil
}

在这两个函数中，我们首先使用kubeconfig文件的路径创建一个配置，然后创建一个客户端用于与Kubernetes集群进行交互。接下来，我们使用客户端调用相应的API来获取服务列表或创建新服务。注意，这里的context和metav1包需要导入，并且这里的代码示例假设你已经有了必要的权限和RBAC配置。