kubernetes的api定义与装载

Tags: kubernetes 

目录

Kubernetes-apiserverKubernetes-apiserver-storage中分析了apiserver是怎样工作、怎样实现了REST API的。

这里分析一下api中的定义的装载。

都有哪些api

kubectl api-versions可以看到集群支持的api:

$ kubectl api-versions
apps/v1beta1
authentication.k8s.io/v1beta1
authorization.k8s.io/v1beta1
autoscaling/v1
batch/v1
certificates.k8s.io/v1alpha1
extensions/v1beta1
policy/v1beta1
rbac.authorization.k8s.io/v1alpha1
storage.k8s.io/v1beta1
v1

这个可以通过kube-apiserver的--runtime-config来设置:

--runtime-config=/api=true,api/all=true,apis=true,apis/v1=true

api在哪里定义的?

api在pkg/api/pkg/apis中定义, pkg/api目录中定义了pod等基础api,pkg/apis中定义的是扩展的api。

▾ api/
  ▸ annotations/
  ▸ endpoints/
  ▸ errors/
  ▸ events/
  ▸ install/
  ▸ meta/

▾ apis/
  ▸ abac/
  ▸ apps/
  ▸ authentication/
  ▸ authorization/
  ▸ autoscaling/
  ▸ batch/
  ▸ certificates/
  ▸ componentconfig/
  ▸ extensions/
  ▸ imagepolicy/
  ▸ meta/
  ▸ policy/
  ▸ rbac/
  ▸ settings/
  ▸ storage/

api是怎样被装载的?

如果你仔细查看api/和apis/的子目录,会发现很多都有一个名为install的目录(不是全部)。

这个目录中有一个名为install.go的文件,里面有这样一个init()函数:

func init() {
	Install(api.GroupFactoryRegistry, api.Registry, api.Scheme)
}

它调用的Install()函数,也在这个文件里实现:

func Install(groupFactoryRegistry announced.APIGroupFactoryRegistry, 
		registry *registered.APIRegistrationManager, scheme *runtime.Scheme) {
	...

Install()将完成api的装载,但是这个过程比较复杂,在下一节中分析。

问题是这些init()函数是什么时候给调用的?通过搜索、回溯代码发现了这个过程。

kube-apiserver的代码cmd/kube-apiserver/app/server.go:67中导入了名为master的package:

"k8s.io/kubernetes/pkg/master"

master的代码pkg/master/import_known_versions.go中导入了api/和apis/子目录中的install:

// These imports are the API groups the API server will support.
import (
    "fmt"
    "k8s.io/kubernetes/pkg/api"
    _ "k8s.io/kubernetes/pkg/api/install"
    _ "k8s.io/kubernetes/pkg/apis/apps/install"
    _ "k8s.io/kubernetes/pkg/apis/authentication/install"
    _ "k8s.io/kubernetes/pkg/apis/authorization/install"
    _ "k8s.io/kubernetes/pkg/apis/autoscaling/install"
    _ "k8s.io/kubernetes/pkg/apis/batch/install"
    _ "k8s.io/kubernetes/pkg/apis/certificates/install"
    _ "k8s.io/kubernetes/pkg/apis/componentconfig/install"
    _ "k8s.io/kubernetes/pkg/apis/extensions/install"
    _ "k8s.io/kubernetes/pkg/apis/imagepolicy/install"
    _ "k8s.io/kubernetes/pkg/apis/policy/install"
    _ "k8s.io/kubernetes/pkg/apis/rbac/install"
    _ "k8s.io/kubernetes/pkg/apis/settings/install"
    _ "k8s.io/kubernetes/pkg/apis/storage/install"
)
...

因此init()函数得以执行,完成api的装载。

api的装载过程

这里以”k8s.io/kubernetes/pkg/api/install”为例。

pkg/api/install/install.go中实现了init()函数,用来装载pkg/api目录下定义的资源:

// Package install installs the v1 monolithic api, making it available as an
// option to all of the API encoding/decoding machinery.
func init() {
    Install(api.GroupFactoryRegistry, api.Registry, api.Scheme)
}

// Install registers the API group and adds types to a scheme
func Install(groupFactoryRegistry announced.APIGroupFactoryRegistry, registry *registered.APIRegistrationManager, scheme *runtime.Scheme) {
    if err := announced.NewGroupMetaFactory(
        &announced.GroupMetaFactoryArgs{
            GroupName:                  api.GroupName,
            VersionPreferenceOrder:     []string{v1.SchemeGroupVersion.Version},
            ImportPrefix:               "k8s.io/kubernetes/pkg/api",
            AddInternalObjectsToScheme: api.AddToScheme,
            RootScopedKinds: sets.NewString(
                "Node",
                "Namespace",
                "PersistentVolume",
                "ComponentStatus",
            ),
            IgnoredKinds: sets.NewString(
                "ListOptions",
                "DeleteOptions",
                "Status",
                "PodLogOptions",
                "PodExecOptions",
                "PodAttachOptions",
                "PodPortForwardOptions",
                "PodProxyOptions",
                "NodeProxyOptions",
                "ServiceProxyOptions",
                "ThirdPartyResource",
                "ThirdPartyResourceData",
                "ThirdPartyResourceList",
            ),
        },
        announced.VersionToSchemeFunc{
            v1.SchemeGroupVersion.Version: v1.AddToScheme,
        },
    ).Announce(groupFactoryRegistry).RegisterAndEnable(registry, scheme); err != nil {
        panic(err)
    }
}

Install()函数的实现中可以看到,Install的过程是通过announced.NewGroupMetaFactory()完成的:

announced.NewGroupMetaFactory().Annouce().RegisterAndEnable()

announced是"k8s.io/apimachinery/pkg/apimachinery/announced"

通过走读代码,可以知道这里是将api的定义注册到了”k8s.io/kubernetes/pkg/api”中的GroupFactoryRegistry中:

var GroupFactoryRegistry = make(announced.APIGroupFactoryRegistry)

其它apis分组目录下的资源也注册到了这个GroupFactoryRegistry中。

有三个参数需要关注:

api.GroupName
api.AddToScheme
v1.SchemeGroupVersion.Version: v1.AddToScheme,

TODO:分析这个过程。

v1.AddToScheme

pkg/api/v1/register.go:

var (
    SchemeBuilder = runtime.NewSchemeBuilder(addKnownTypes, addDefaultingFuncs, addConversionFuncs, addFastPathConversionFuncs)
    AddToScheme   = SchemeBuilder.AddToScheme
)

AddToScheme是一个函数,它的作用就是调用SchemeBuilder中注册的函数:

func (sb *SchemeBuilder) AddToScheme(s *Scheme) error {
    for _, f := range *sb {
        if err := f(s); err != nil {
            return err
        }
    }
    return nil
}

也就是SchemeBuilder创建时传入的函数:

addKnownTypes, 
addDefaultingFuncs, 
addConversionFuncs, 
addFastPathConversionFuncs

api/v1中的addKnownTypes():

// Adds the list of known types to api.Scheme.
func addKnownTypes(scheme *runtime.Scheme) error {
    scheme.AddKnownTypes(SchemeGroupVersion,
        &Pod{},
        &PodList{},
        &PodStatusResult{},
        &PodTemplate{},
        &PodTemplateList{},
        &ReplicationController{},
        &ReplicationControllerList{},
        &Service{},
        &ServiceProxyOptions{},
        &ServiceList{},
        &Endpoints{},
        &EndpointsList{},
        &Node{},
        &NodeList{},
        &NodeProxyOptions{},
        &Binding{},
        &Event{},
        &EventList{},
        &List{},
...

参考

  1. Kubernetes-apiserver
  2. Kubernetes-apiserver-storage

kubernetes

  1. kubernetes 使用:多可用区、Pod 部署拓扑与 Topology Aware Routing
  2. kubernetes 扩展:Cloud Controller Manager
  3. kubernetes 准入:操作合法性检查(Admission Control)
  4. kubernetes 鉴权:用户操作权限鉴定(Authorization)
  5. kubernetes 认证:用户管理与身份认证(Authenticating)
  6. kubernetes 开发:代码生成工具
  7. kubernetes 扩展:operator 开发
  8. kubernetes 扩展:CRD 的使用方法
  9. kubernetes configmap 热加载,inotifywatch 监测文件触发热更新
  10. kubernetes 扩展:扩展点和方法(api/cr/plugin...)
  11. kubernetes 调度组件 kube-scheduler 1.16.3 源代码阅读指引
  12. kubernetes 代码中的 k8s.io 是怎么回事?
  13. 阅读笔记《不一样的 双11 技术,阿里巴巴经济体云原生实践》
  14. kubernetes ingress-nginx 启用 upstream 长连接,需要注意,否则容易 502
  15. ingress-nginx 的限速功能在 nginx.conf 中的对应配置
  16. kubernetes 中的容器设置透明代理,自动在 HTTP 请求头中注入 Pod 信息
  17. kubernetes ingress-nginx 的测试代码(单元测试+e2e测试)
  18. kubernetes ingress-nginx http 请求复制功能与 nginx mirror 的行为差异
  19. kubernetes 基于 openresty 的 ingress-nginx 的状态和配置查询
  20. kubernetes ingress-nginx 0.25 源代码走读笔记
  21. kubernetes ingress-nginx 的金丝雀(canary)/灰度发布功能的使用方法
  22. kubernetes 操作命令 kubectl 在 shell 中的自动补全配置
  23. kubernetes 组件 kube-proxy 的 IPVS 功能的使用
  24. kubernetes initializer 功能的使用方法: 在 Pod 等 Resource 落地前进行修改
  25. kubernetes 版本特性: 新特性支持版本和组件兼容版本
  26. kubernetes API 与 Operator: 不为人知的开发者战争(完整篇)
  27. kubernetes 1.12 从零开始(七): kubernetes开发资源
  28. kubernetes 1.12 从零开始(六): 从代码编译到自动部署
  29. kubernetes 网络方案 Flannel 的学习笔记
  30. kubernetes 1.12 从零开始(五): 自己动手部署 kubernetes
  31. kubernetes 1.12 从零开始(四): 必须先讲一下基本概念
  32. kubernetes 1.12 从零开始(三): 用 kubeadm 部署多节点集群
  33. kubernetes 1.12 从零开始(二): 用 minikube 部署开发测试环境
  34. kubernetes 1.12 从零开始(一): 部署环境准备
  35. kubernetes 1.12 从零开始(零): 遇到的问题与解决方法
  36. kubernetes 1.12 从零开始(初): 课程介绍与官方文档汇总
  37. kubernetes 集群状态监控:通过 grafana 和 prometheus
  38. 一些比较有意思的Kubernetes周边产品
  39. Borg论文阅读笔记
  40. kubelet下载pod镜像时,docker口令文件的查找顺序
  41. kubernetes 的 Client Libraries 的使用
  42. kubernetes的网络隔离networkpolicy
  43. kube-router的源码走读
  44. kubernetes 跨网段通信: 通过 calico 的 ipip 模式
  45. kubernetes的调试方法
  46. kubernetes 与 calico 的衔接过程
  47. 怎样理解 kubernetes 以及微服务?
  48. kubernetes中部署有状态的复杂分布式系统
  49. kubernetes的apiserver的启动过程
  50. kubernetes的api定义与装载
  51. kubernetes的federation部署,跨区Service
  52. kubernetes的编译、打包、发布
  53. kubernetes的第三方包的使用
  54. kubernetes的Storage的实现
  55. kubernetes 的 Apiserver 的 storage 使用
  56. kubernetes的Controller-manager的工作过程
  57. kubernetes的Client端Cache
  58. kubernetes 的 Apiserver 的工作过程
  59. kubernetes的CNI插件初始化与Pod网络设置
  60. kubernetes的Pod变更过程
  61. kubernetes的kubelet的工作过程
  62. kuberntes 的 Cmdline 实现
  63. kubernetes的Pod内挂载的Service Account的使用方法
  64. kubernetes的社区资源与项目参与方式
  65. kubernetes的Kube-proxy的转发规则分析
  66. kubernetes的基本操作
  67. kubernetes在CentOS上的集群部署
  68. kubernetes在CentOS上的All In One部署
  69. 怎样选择集群管理系统?

推荐阅读

Copyright @2011-2019 All rights reserved. 转载请添加原文连接,合作请加微信lijiaocn或者发送邮件: [email protected],备注网站合作

友情链接:  系统软件  程序语言  运营经验  水库文集  网络课程  微信网文  发现知识星球