File was renamed from src/create/main.go |
| | |
| | | package create |
| | | package k8s |
| | | |
| | | import ( |
| | | "context" |
| | |
| | | "fmt" |
| | | "log" |
| | | "math/rand" |
| | | "os" |
| | | "path/filepath" |
| | | |
| | | "../util" |
| | | appsv1 "k8s.io/api/apps/v1" |
| | | apiv1 "k8s.io/api/core/v1" |
| | | "k8s.io/apimachinery/pkg/api/errors" |
| | |
| | | |
| | | func main() { |
| | | // 配置 Kubernetes 集群的 kubeconfig 路径 |
| | | kubeconfig := flag.String("kubeconfig", filepath.Join(homeDir(), ".kube", "config"), "kubeconfig file") |
| | | kubeconfig := flag.String("kubeconfig", filepath.Join(util.HomeDir(), ".kube", "config"), "kubeconfig file") |
| | | flag.Parse() |
| | | |
| | | // 创建 Kubernetes 客户端 |
| | |
| | | } |
| | | |
| | | return false, nil |
| | | } |
| | | |
| | | // homeDir 获取当前用户的家目录路径 |
| | | func homeDir() string { |
| | | if h := os.Getenv("HOME"); h != "" { |
| | | return h |
| | | } |
| | | return os.Getenv("USERPROFILE") // Windows 环境下获取用户目录 |
| | | } |
| | | |
| | | // GetServiceNodePort 获取指定 Service 的 NodePort |