首先使用client-go库创建Kubernetes客户端，再通过Clientset操作ConfigMap和Secret：1. 创建ConfigMap存储非敏感配置；2. 获取并更新其数据；3. 创建Secret以Base64编码存储敏感信息；4. 获取并更新Secret内容。需注意命名空间、权限及编码格式。
在Kubernetes中，ConfigMap和Secret是两种常用的资源对象，用于管理配置数据和敏感信息。使用Golang可以通过官方提供的client-go库与Kubernetes API交互，实现对ConfigMap和Secret的增删改查操作。下面介绍具体实现方式。
准备环境与依赖
要通过Golang操作Kubernetes资源，需引入client-go库，并正确配置访问集群的凭证。
- 安装client-go：
go get k8s.io/client-go@latest
- 确保kubeconfig文件存在（通常位于~/.kube/config），或在代码中指定路径。
- 导入必要包：
import (
立即学习“go语言免费学习笔记（深入）”；
"context"
"fmt"
"k8s.io/apimachinery/pkg/api/errors"
"k8s.io/apimachinery/pkg/api/resource"
"k8s.io/apimachinery/pkg/util/intstr"
"k8s.io/client-go/kubernetes"
"k8s.io/client-go/tools/clientcmd"
)
创建Kubernetes客户端
使用kubeconfig初始化REST配置并构建Clientset实例。
func newClient() (*kubernetes.Clientset, error) {
config, err := clientcmd.BuildConfigFromFlags("", clientcmd.RecommendedHomeFile)
if err != nil {
return nil, err
}
return kubernetes.NewForConfig(config)
}
操作ConfigMap
ConfigMap用于存储非敏感配置，如环境变量、配置文件内容等。
- 创建ConfigMap
cm := &v1.ConfigMap{
ObjectMeta: metav1.ObjectMeta{Name: "app-config", Namespace: "default"},
Data: map[string]string{
"log.level": "info",
"timeout": "30s",
},
}
_, err := client.CoreV1().ConfigMaps("default").Create(context.TODO(), cm, metav1.CreateOptions{})
- 获取ConfigMap
cm, err := client.CoreV1().ConfigMaps("default").Get(context.TODO(), "app-config", metav1.GetOptions{})
if errors.IsNotFound(err) {
fmt.Println("ConfigMap not found")
} else if err != nil {
fmt.Printf("Error: %v\n", err)
} else {
fmt.Println("Log level:", cm.Data["log.level"])
}
- 更新ConfigMap
先获取再修改后调用Update：
cm.Data["log.level"] = "debug"
_, err = client.CoreV1().ConfigMaps("default").Update(context.TODO(), cm, metav1.UpdateOptions{})
操作Secret
Secret用于存储敏感数据，如密码、密钥等，其值需以Base64编码。
- 创建Secret
secret := &v1.Secret{
ObjectMeta: metav1.ObjectMeta{Name: "db-secret", Namespace: "default"},
Type: v1.SecretTypeOpaque,
StringData: map[string]string{
"username": "admin",
"password": "s3cr3t",
},
}
_, err := client.CoreV1().Secrets("default").Create(context.TODO(), secret, metav1.CreateOptions{})
- 获取Secret
sec, err := client.CoreV1().Secrets("default").Get(context.TODO(), "db-secret", metav1.GetOptions{})
if err != nil {
fmt.Printf("Error: %v\n", err)
return
}
fmt.Println("Username:", string(sec.Data["username"]))
fmt.Println("Password:", string(sec.Data["password"]))
- 更新Secret
修改字段后调用Update方法：
sec.StringData["password"] = "newpass123"
_, err = client.CoreV1().Secrets("default").Update(context.TODO(), sec, metav1.UpdateOptions{})
基本上就这些。只要掌握client-go的基本用法，操作ConfigMap和Secret并不复杂，但要注意命名空间、权限和数据编码问题。
