在上一篇API多版本初探中已经描述了API资源是如何注册到路由当中，并大概介绍了api请求如何根据优先版本存储到etcd中。本篇文章主要介绍apiserver如何将etcd中的数据按照按照用户指定的版本返回。在探究同一个api group下不同版本资源兼容问题之外，还会探究不同api group下的不同资源是如何做到兼容的。本文基于kubernetes-1.19.11版本。
本文关注的重点内容有：
apiserver如何读取解析etcd中的数据
apiserver怎么返回用户指定的版本资源
不同api group怎么做到兼容，如netwoking.k8s.io/v1beta1下的Ingress资源和extensions/v1beta1下的Ingress资源
在阅读源码过程中在protobuf处理关键位置加入了打印堆栈日志，先找出整个函数调用链，再根据链路分析整个执行流程会更容易的多，具体修改和打印的栈信息可在后面的附录中查看。
首先看pkg/master/import_known_versions.go这个文件，该文件中有许多xxx/install的import。
import (
// These imports are the API groups the API server will support.
_ "k8s.io/kubernetes/pkg/apis/admission/install"
_ "k8s.io/kubernetes/pkg/apis/admissionregistration/install"
_ "k8s.io/kubernetes/pkg/apis/apps/install"
...
来看下这个文件的作用。从文件的名称来看就知道是导入所有的所有已知的api版本，在install包的init函数中会将所有已定义的资源加载到runtime schema中，主要包含下面两类：
在pkg/apis/${group}/types.go中定义的类型
在k8s.io/api/${group}/${version}/types.go中定义的
第1类资源代表了内部版本的表示方法，是在etcd中读取的数据（或api请求数据）反序列化之后的表示类型。第2类资源为不同的group下特定version的类型，在写入etcd的（或api响应的）数据是根据特定group/version下的类型进行序列化的。
在install中有一个SetVersionPriority()方法，用来设置写入etcd是优先使用的版本。当然第2类资源在注册的时候还会加上一些设置默认值和转换到内部版本或从内部版本转换的方法来实现内部版本和外部版本之间的互相转换。这些方法的定义在pkg/apis/${group}/${version}下的default.go，conversion.go，zz_generated.xxx.go中定义的。
接下来以Ingress资源来说明转换的读取，转换，返回响应的流程，首先通过加日志查看当前runtime schema中可以看到有三个Ingress类型的定义。分别对应的是extensions/v1beta1，networking.k8s.io/v1beta1和内部版本，可以看到内部版本有两个，分别是extensions/__internal和networking.k8s.io/__internal，但是其他俩对应的实际类型都是pkg/apis/networking/types.go中定义的Ingress类型。
再来回顾一下加载api资源注册路由部分，有一个InstallAPIs()方法，该参数中的networkingrest.RESTStorageProvider{}来自pkg/registry/networking/rest/storage_settings.go中定义的storage接口，这个storage接口设置了ingresses资源对应ingressStorage。
func (p RESTStorageProvider) v1beta1Storage(apiResourceConfigSource serverstorage.APIResourceConfigSource, restOptionsGetter generic.RESTOptionsGetter) (map[string]rest.Storage, error) {
storage := map[string]rest.Storage{}
// ingresses
ingressStorage, ingressStatusStorage, err := ingressstore.NewREST(restOptionsGetter)
if err != nil {
return storage, err
}
storage["ingresses"]…
kube-apiserver代码分析 – API多版本再探
发布于