你可以使用Kubernetes Go库创建一个简单的客户端应用程序。

huangapple
go评论196阅读模式
英文:

How can I create a simple client app with the Kubernetes Go library?

问题

我正在与Kubernetes Go库进行斗争。文档（至少我找到的那些）似乎与库本身不符。提供的示例由于导入问题而无法构建。我只是想做一些简单的事情：通过名称获取一个Service对象并打印一些属性（如nodePort）。我只需要一个简单的库用法示例来帮助我入门。

我可以使用RESTful API轻松完成这个任务，但感觉这样做是在重复造轮子。

英文:

I'm struggling with the Kubernetes Go library. The docs--at least the ones I found--appear out-of-date with the library itself. The example provided does not build because of issues with the imports. I'm just trying to do something simple: get a Service object by name and print some attributes (like nodePort). I just need a simple example of library usage to get me going.

I could easily do this using the RESTful API but that feels like re-inventing the wheel.

答案1

得分: 7

以下是翻译好的内容：

所以经过一些实验和来自k8s Slack频道的提示，我有了这个示例。也许有人可以用正确的导入路径更新这个示例。

  1. package main
  3. import (
  4. 	"fmt"
  5. 	"log"
  7. 	"github.com/kubernetes/kubernetes/pkg/api"
  8. 	client "github.com/kubernetes/kubernetes/pkg/client/unversioned"
  9. )
  11. func main() {
  13. 	config := client.Config{
  14. 		Host: "http://my-kube-api-server.me:8080",
  15. 	}
  16. 	c, err := client.New(&config)
  17. 	if err != nil {
  18. 		log.Fatalln("无法连接到Kubernetes API：", err)
  19. 	}
  21. 	s, err := c.Services(api.NamespaceDefault).Get("some-service-name")
  22. 	if err != nil {
  23. 		log.Fatalln("无法获取服务：", err)
  24. 	}
  25. 	fmt.Println("名称：", s.Name)
  26. 	for p, _ := range s.Spec.Ports {
  27. 		fmt.Println("端口：", s.Spec.Ports[p].Port)
  28. 		fmt.Println("NodePort：", s.Spec.Ports[p].NodePort)
  29. 	}
  30. }

希望对你有帮助！

英文:

So after a little experimentation and a hint from the k8s Slack channel, I have this example. Perhaps someone can update the example with a proper import path.

  1. package main
  3. import (
  4.     "fmt"
  5.     "log"
  7.     "github.com/kubernetes/kubernetes/pkg/api"
  8.     client "github.com/kubernetes/kubernetes/pkg/client/unversioned"
  9. )
  11. func main() {
  13. 	config := client.Config{
  14.     	Host: "http://my-kube-api-server.me:8080",
  15. 	}
  16.     c, err := client.New(&config)
  17. 	if err != nil {
  18.     	log.Fatalln("Can't connect to Kubernetes API:", err)
  19.     }
  21. 	s, err := c.Services(api.NamespaceDefault).Get("some-service-name")
  22.     if err != nil {
  23. 	    log.Fatalln("Can't get service:", err)
  24. 	}
  25.     fmt.Println("Name:", s.Name)
  26.     for p, _ := range s.Spec.Ports {
  27. 	    fmt.Println("Port:", s.Spec.Ports
    .Port)
  28. 		fmt.Println("NodePort:", s.Spec.Ports
    .NodePort)
  29.     }
  30. }

答案2

得分: 5

以下是最新的Go客户端的操作方法。

如果你在k8s集群内部：

  1. package main
  3. import (
  4.   "fmt"
  6.   "k8s.io/client-go/1.5/kubernetes"
  7.   "k8s.io/client-go/1.5/pkg/api/v1"
  8.   "k8s.io/client-go/1.5/rest"
  9. )
  11. func main()  {
  12.     config, err := rest.InClusterConfig()
  13.     if err != nil {
  14.       return nil, err
  15.     }
  17.     c, err := kubernetes.NewForConfig(config)
  18.     if err != nil {
  19.       return nil, err
  20.     }
  22.     // 通过名称获取Pod
  23.     pod, err := c.Pods(v1.NamespaceDefault).Get("my-pod")
  24.     if err != nil {
  25.         fmt.Println(err)
  26.         return
  27.     }
  28.   
  29.     // 打印创建时间
  30.     fmt.Println(pod.GetCreationTimestamp())
  31. }

如果你在集群外部：

  1. package main
  3. import (
  4.   "fmt"
  6.   "k8s.io/client-go/1.5/kubernetes"
  7.   "k8s.io/client-go/1.5/pkg/api/v1"
  8.   "k8s.io/client-go/1.5/tools/clientcmd"
  9. )
  11. func main()  {
  12.     config, err := clientcmd.BuildConfigFromFlags("", "<kube-config-path>")
  13.     if err != nil {
  14.       return nil, err
  15.     }
  17.     c, err := kubernetes.NewForConfig(config)
  18.     if err != nil {
  19.       return nil, err
  20.     }
  22.     // 通过名称获取Pod
  23.     pod, err := c.Pods(v1.NamespaceDefault).Get("my-pod")
  24.     if err != nil {
  25.         fmt.Println(err)
  26.         return
  27.     }
  28.   
  29.     // 打印创建时间
  30.     fmt.Println(pod.GetCreationTimestamp())
  31. }

我在博客文章中对此进行了更详细的说明。

英文:

Here's how to do it with the latest Go client.

If you're inside the k8s cluster:

  1. package main
  3. import (
  4.   &quot;fmt&quot;
  6.   &quot;k8s.io/client-go/1.5/kubernetes&quot;
  7.   &quot;k8s.io/client-go/1.5/pkg/api/v1&quot;
  8.   &quot;k8s.io/client-go/1.5/rest&quot;
  9. )
  11. func main()  {
  12.     config, err = rest.InClusterConfig()
  13.     if err != nil {
  14.       return nil, err
  15.     }
  17.     c, err := kubernetes.NewForConfig(config)
  18.     if err != nil {
  19.       return nil, err
  20.     }
  22.     // Get Pod by name
  23.     pod, err := c.Pods(v1.NamespaceDefault).Get(&quot;my-pod&quot;)
  24.     if err != nil {
  25.         fmt.Println(err)
  26.         return
  27.     }
  28.   
  29.     // Print its creation time
  30.     fmt.Println(pod.GetCreationTimestamp())
  31. }

And if you're outside of the cluster:

  1. package main
  3. import (
  4.   &quot;fmt&quot;
  6.   &quot;k8s.io/client-go/1.5/kubernetes&quot;
  7.   &quot;k8s.io/client-go/1.5/pkg/api/v1&quot;
  8.   &quot;k8s.io/client-go/1.5/tools/clientcmd&quot;
  9. )
  11. func main()  {
  12.     config, err := clientcmd.BuildConfigFromFlags(&quot;&quot;, &lt;kube-config-path&gt;)
  13.     if err != nil {
  14.       return nil, err
  15.     }
  17.     c, err := kubernetes.NewForConfig(config)
  18.     if err != nil {
  19.       return nil, err
  20.     }
  22.     // Get Pod by name
  23.     pod, err := c.Pods(v1.NamespaceDefault).Get(&quot;my-pod&quot;)
  24.     if err != nil {
  25.         fmt.Println(err)
  26.         return
  27.     }
  28.   
  29.     // Print its creation time
  30.     fmt.Println(pod.GetCreationTimestamp())
  31. }

I have gone into more detail on this in a blog post.

答案3

得分: 3

使用Kubernetes Go客户端，可以按照以下方式完成：

  1. package main
  3. import (
  4. 	"flag"
  5. 	"fmt"
  7. 	"k8s.io/client-go/kubernetes"
  8. 	"k8s.io/client-go/pkg/api/v1"
  9. 	"k8s.io/client-go/tools/clientcmd"
  10. )
  12. var (
  13. 	kubeconfig = flag.String("kubeconfig", "./config", "kubeconfig文件的绝对路径")
  14. )
  16. func main() {
  17. 	flag.Parse()
  18. 	// 使用kubeconfig中的当前上下文
  19. 	config, err := clientcmd.BuildConfigFromFlags("", *kubeconfig)
  20. 	if err != nil {
  21. 		panic(err.Error())
  22. 	}
  23. 	// 创建clientset
  24. 	clientset, err := kubernetes.NewForConfig(config)
  25. 	if err != nil {
  26. 		panic(err.Error())
  27. 	}
  28. 	services, err := clientset.Core().Services("").List(v1.ListOptions{})
  29. 	if err != nil {
  30. 		panic(err.Error())
  31. 	}
  32. 	fmt.Printf("集群中有 %d 个服务\n", len(services.Items))
  34. 	for _, s := range services.Items {
  35. 		for p, _ := range s.Spec.Ports {
  36. 			fmt.Println("端口:", s.Spec.Ports[p].Port)
  37. 			fmt.Println("NodePort:", s.Spec.Ports[p].NodePort)
  38. 		}
  39. 	}
  40. }

以上是使用Kubernetes Go客户端的示例代码。

英文:

With kubernetes go client, it could be done this way:

  1. package main
  3. import (
  4. 	&quot;flag&quot;
  5. 	&quot;fmt&quot;
  7. 	&quot;k8s.io/client-go/kubernetes&quot;
  8. 	&quot;k8s.io/client-go/pkg/api/v1&quot;
  9. 	&quot;k8s.io/client-go/tools/clientcmd&quot;
  10. )
  12. var (
  13. 	kubeconfig = flag.String(&quot;kubeconfig&quot;, &quot;./config&quot;, &quot;absolute path to the kubeconfig file&quot;)
  14. )
  16. func main() {
  17. 	flag.Parse()
  18. 	// uses the current context in kubeconfig
  19. 	config, err := clientcmd.BuildConfigFromFlags(&quot;&quot;, *kubeconfig)
  20. 	if err != nil {
  21. 		panic(err.Error())
  22. 	}
  23. 	// creates the clientset
  24. 	clientset, err := kubernetes.NewForConfig(config)
  25. 	if err != nil {
  26. 		panic(err.Error())
  27. 	}
  28. 	services, err := clientset.Core().Services(&quot;&quot;).List(v1.ListOptions{})
  29. 	if err != nil {
  30. 		panic(err.Error())
  31. 	}
  32. 	fmt.Printf(&quot;There are %d pods in the cluster\n&quot;, len(services.Items))
  34. 	for _, s := range services.Items {
  35. 		for p, _ := range s.Spec.Ports {
  36. 			fmt.Println(&quot;Port:&quot;, s.Spec.Ports
    .Port)
  37. 			fmt.Println(&quot;NodePort:&quot;, s.Spec.Ports
    .NodePort)
  38. 		}
  39. 	}
  40. }

huangapple
  • 本文由 发表于 2015年9月14日 05:53:41
  • 转载请务必保留本文链接：https://go.coder-hub.com/32554893.html
  • go
  • kubernetes
匿名

发表评论

匿名网友

:?: :razz: :sad: :evil: :!: :smile: :oops: :grin: :eek: :shock: :???: :cool: :lol: :mad: :twisted: :roll: :wink: :idea: :arrow: :neutral: :cry: :mrgreen:

确定