Istio client-go 发布公告
正式启用访问 Istio 资源。
我们很高兴地宣布 Istio client go 的第一个版本发布了,该存储库使开发人员能够在 Kubernetes 环境中访问 Istio API 。在此存储库中的 Kubernetes 程序和客户端使开发人员可以轻松地为所有 Istio 客户端自定义的资源 (CRDs) 创建,读取,更新和删除 (CRUD)。
这是许多 Istio 用户强烈要求的功能,从 Aspen Mesh 和 Knative project 项目对客户端产生的功能请求中可以明显地看出这一点。如果您正在使用上述客户端之一,则可以像如下这样轻松地切换到 Istio client go:
import (
...
- versionedclient "github.com/aspenmesh/istio-client-go/pkg/client/clientset/versioned"
+ versionedclient "istio.io/client-go/pkg/clientset/versioned"
)由于生成的客户端在功能上是等效的,因此使用新的 istio-client-go 也不会有什么问题。
如何使用客户端
Istio client go 存储库遵循与 Istio API 存储库 相同的分支策略,因为客户端存储库取决于 API 定义。如果要使用稳定的客户端,则可以在 client go 存储库中使用发行版分支或标记的版本。使用客户端与使用 Kubernetes client go 非常相似,这是一个使用客户端列出命名空间中所有 Istio
virtual services 的简单示例:
package main
import (
"log"
"os"
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
"k8s.io/client-go/tools/clientcmd"
versionedclient "istio.io/client-go/pkg/clientset/versioned"
)
func main() {
kubeconfig := os.Getenv("KUBECONFIG")
namespace := os.Getenv("NAMESPACE")
if len(kubeconfig) == 0 || len(namespace) == 0 {
log.Fatalf("Environment variables KUBECONFIG and NAMESPACE need to be set")
}
restConfig, err := clientcmd.BuildConfigFromFlags("", kubeconfig)
if err != nil {
log.Fatalf("Failed to create k8s rest client: %s", err)
}
ic, err := versionedclient.NewForConfig(restConfig)
if err != nil {
log.Fatalf("Failed to create istio client: %s", err)
}
// Print all VirtualServices
vsList, err := ic.NetworkingV1alpha3().VirtualServices(namespace).List(metav1.ListOptions{})
if err != nil {
log.Fatalf("Failed to get VirtualService in %s namespace: %s", namespace, err)
}
for i := range vsList.Items {
vs := vsList.Items[i]
log.Printf("Index: %d VirtualService Hosts: %+v\n", i, vs.Spec.GetHosts())
}
}您可以在这里找到更详尽的示例。
为生成 Istio client go 而创建的工具
如果您想知道为什么花费大量时间也很难生成此客户端,本小节将对此进行说明。在 Istio 中,我们使用 protobuf 规范编写 API,然后使用 protobuf 工具链将其转换为 Go 定义。如果尝试从 protobuf 的 API 生成 Kubernetes 客户端,可能会面临三个主要的挑战:
创建 Kubernetes 装饰器类型 - Kubernetes 客户端生成库 仅适用于遵循
Kubernetes对象规范的Go对象,例如:Authentication Policy Kubernetes Wrappers。这意味着对于需要程序访问的每个 API,您都需要创建这些装饰器。此外,每个CRD组,版本和种类都需要大量的样板,需要用客户端代码生成。为了自动化该过程,我们创建了一个 Kubernetes type generator 工具,可以基于注释去自动创建Kubernetes类型。该工具的注释和各种可用选项在 README 中进行了说明。请注意,如果您使用protobuf工具生成Go类型,则需要将这些注释添加到proto文件中,以便注释出现在生成的Go文件中,然后供该工具使用。生成 deep copy 方法 - 在
Kubernetes客户端机制中,如果您想对从客户端集返回的任何对象进行修改,则需要创建该对象的副本以防止直接修改缓存中的对象。为了不直接修改缓存中的对象,我们一般是在所有嵌套类型上创建一个deep copy方法。我们开发了一个 protoc deep copy generator 工具 ,该工具是一个protoc插件,可以使用 Proto Clone 库上的注释自动创建deepcopy方法。这是一个生成了deepcopy方法的示例。类型和 JSON 的互相转换 - 对于从
proto定义生成的类型,使用默认的Go JSON编码器或解码器通常会出现问题,因为像protobuf的oneof这类字段需要进行特殊处理。另外,名称中带有下划线的任何Proto字段都可以序列化或反序列化为不同的字段名称,具体取决于编码器/解码器,因为Go结构体的标记方式不同。始终建议使用protobuf原语对JSON进行序列化或反序列化,而不是依赖默认的Go库。我们创建了一个 protoc JSON shim 工具,它是一个protoc插件,可以为从Proto定义所有Go类型自动创建的Marshalers或Unmarshalers。这是用此工具生成代码的一个示例。
我们希望新发布的客户端使用户能够为 Istio API 创建更多的 integrations 和 controllers,并且开发人员可以使用上述工具从 Proto API 生成 Kubernetes 客户端。