1# 获取所有的资源组和版本
2kubectl api-versions
3# 获取所有的资源
4kubectl api-resources

 1mkdir $GOPATH/src/k8s.io
 2cd $GOPATH/src/k8s.io
 3
 4# 通过go get获取
 5GO111MODULE=on GOPROXY=https://goproxy.cn/,direct go get -d -v k8s.io/kubernetes@v1.14.0
 6
 7# 通过git克隆
 8git clone  https://github.com/kubernetes/kubernetes -b release-1.14
 9
10# 编译
11cd kubernetes
12# 指定编译平台、编译所有组件、开启verbose日志、禁止编译优化
13KUBE_BUILD_PLATFORMS=linux/amd64 make all GOFLAGS=-v GOGCFLAGS="-N -l"

 1type Object interface {
 2  // 设置并返回ObjectKind
 3  GetObjectKind() schema.ObjectKind
 4  // 深拷贝当前资源对象
 5  DeepCopyObject() Object
 6}
 7
 8type ObjectKind interface {
 9  SetGroupVersionKind(kind GroupVersionKind)
10  GroupVersionKind() GroupVersionKind
11}

 1type APIResource struct {
 2  // 资源名称（复数形式）
 3  Name string `json:"name" protobuf:"bytes,1,opt,name=name"`
 4
 5  // 资源名称（单数形式）
 6  SingularName string `json:"singularName" protobuf:"bytes,6,opt,name=singularName"`
 7
 8  // 命名空间
 9  Namespaced bool `json:"namespaced" protobuf:"varint,2,opt,name=namespaced"`
10
11  // 资源分组
12  Group string `json:"group,omitempty" protobuf:"bytes,8,opt,name=group"`
13
14  // 资源版本
15  Version string `json:"version,omitempty" protobuf:"bytes,9,opt,name=version"`
16
17  // 资源类型
18  Kind string `json:"kind" protobuf:"bytes,3,opt,name=kind"`
19
20  // 资源可操作的方法列表
21  Verbs Verbs `json:"verbs" protobuf:"bytes,4,opt,name=verbs"`
22
23  // 资源的简称
24  ShortNames []string `json:"shortNames,omitempty" protobuf:"bytes,5,rep,name=shortNames"`
25
26  // 资源所属的类别列表
27  Categories []string `json:"categories,omitempty" protobuf:"bytes,7,rep,name=categories"`
28
29  // 存储版本的hash值，这只是一个试用的功能，将来可能改变或者移除
30  StorageVersionHash string `json:"storageVersionHash,omitempty" protobuf:"bytes,10,opt,name=storageVersionHash"`
31}

1type APIResourceList struct {
2  TypeMeta `json:",inline"`
3  // groupVersion is the group and version this APIResourceList is for.
4  GroupVersion string `json:"groupVersion" protobuf:"bytes,1,opt,name=groupVersion"`
5  // resources contains the name of the resources and if they are namespaced.
6  APIResources []APIResource `json:"resources" protobuf:"bytes,2,rep,name=resources"`
7}

1type GroupVersionResource struct {
2  Group    string
3  Version  string
4  Resource string
5}

 1type APIGroup struct {
 2  TypeMeta `json:",inline"`
 3
 4  // 资源组名称
 5  Name string `json:"name" protobuf:"bytes,1,opt,name=name"`
 6
 7  // 资源组下所支持的资源版本
 8  Versions []GroupVersionForDiscovery `json:"versions" protobuf:"bytes,2,rep,name=versions"`
 9
10  // 首选版本，当存在多个资源版本时，优先选择的版本
11  PreferredVersion GroupVersionForDiscovery `json:"preferredVersion,omitempty" protobuf:"bytes,3,opt,name=preferredVersion"`
12
13  ServerAddressByClientCIDRs []ServerAddressByClientCIDR `json:"serverAddressByClientCIDRs,omitempty" protobuf:"bytes,4,rep,name=serverAddressByClientCIDRs"`
14}

1type APIVersions struct {
2  TypeMeta `json:",inline"`
3  // 所支持的资源版本列表
4  Versions []string `json:"versions" protobuf:"bytes,1,rep,name=versions"`
5
6  ServerAddressByClientCIDRs []ServerAddressByClientCIDR `json:"serverAddressByClientCIDRs" protobuf:"bytes,2,rep,name=serverAddressByClientCIDRs"`
7}

 1// 外部版本
 2type Pod struct {
 3  metav1.TypeMeta `json:",inline"`
 4  // Standard object's metadata.
 5  // More info: https://git.k8s.io/community/contributors/devel/sig-architecture/api-conventions.md#metadata
 6  // +optional
 7  metav1.ObjectMeta `json:"metadata,omitempty" protobuf:"bytes,1,opt,name=metadata"`
 8
 9  // Specification of the desired behavior of the pod.
10  // More info: https://git.k8s.io/community/contributors/devel/sig-architecture/api-conventions.md#spec-and-status
11  // +optional
12  Spec PodSpec `json:"spec,omitempty" protobuf:"bytes,2,opt,name=spec"`
13
14  // Most recently observed status of the pod.
15  // This data may not be up to date.
16  // Populated by the system.
17  // Read-only.
18  // More info: https://git.k8s.io/community/contributors/devel/sig-architecture/api-conventions.md#spec-and-status
19  // +optional
20  Status PodStatus `json:"status,omitempty" protobuf:"bytes,3,opt,name=status"`
21}

 1// 内部版本
 2type Pod struct {
 3  metav1.TypeMeta
 4  // +optional
 5  metav1.ObjectMeta
 6
 7  // Spec defines the behavior of a pod.
 8  // +optional
 9  Spec PodSpec
10
11  // Status represents the current information about a pod. This data may not be up
12  // to date.
13  // +optional
14  Status PodStatus
15}

 1├── BUILD
 2├── OWNERS
 3├── doc.go // 定义包注释信息
 4├── fuzzer
 5├── install
 6├── register.go // 定义了资源组、资源版本、资源注册信息
 7├── types.go // 定了了在当前资源组、资源版本下支持的资源信息
 8├── v1       // 定义了资源组下拥有的v1版本资源
 9│   ├── BUILD
10│   ├── conversion.go  // 定义了资源转换函数（默认的），并将转换函数注册到资源注册表中
11│   ├── conversion_test.go
12│   ├── defaults.go    // 定义了资源默认函数
13│   ├── defaults_test.go
14│   ├── doc.go
15│   ├── register.go
16│   ├── zz_generated.conversion.go // 定义了资源转换函数（自动生成的），由代码生成器生成
17│   └── zz_generated.defaults.go   // 定义了资源默认值（自动生成的）
18├── v1beta1  // 定义了资源组下拥有的v1beta1版本资源
19├── v1beta2  // 定义了资源组下拥有的v1beta2版本资源
20├── validation // 定义了资源的验证方法
21└── zz_generated.deepcopy.go // 定义了资源的深拷贝操作，该文件由代码生成器自动生成

 1type Scheme struct {
 2  // 存储GVK与type的映射关系
 3  gvkToType map[schema.GroupVersionKind]reflect.Type
 4
 5  // 存储type与GVK的映射关系，一个type会对应一个或多个gvk
 6  typeToGVK map[reflect.Type][]schema.GroupVersionKind
 7
 8  // 无版本类型与gvk的映射关系
 9  unversionedTypes map[reflect.Type]schema.GroupVersionKind
10
11  // 资源名称与类型的映射关系
12  unversionedKinds map[string]reflect.Type
13
14  ...
15}

 1
 2func init() {
 3  // legacyscheme.Scheme 是api-server的全局资源注册表
 4  Install(legacyscheme.Scheme)
 5}
 6
 7// Install registers the API group and adds types to a scheme
 8func Install(scheme *runtime.Scheme) {
 9  // 注册内部版本的资源
10  utilruntime.Must(core.AddToScheme(scheme))
11  // 注册外部版本的资源
12  utilruntime.Must(v1.AddToScheme(scheme))
13  // 注册资源组的版本顺序，第一个为首选版本
14  utilruntime.Must(scheme.SetVersionPriority(v1.SchemeGroupVersion))
15}

 1// 编码
 2type Encoder interface {
 3  Encode(obj Object, w io.Writer) error
 4  Identifier() Identifier
 5}
 6
 7// 解码
 8type Decoder interface {
 9  Decode(data []byte, defaults *schema.GroupVersionKind, into Object) (Object, *schema.GroupVersionKind, error)
10}
11
12// 序列化器都实现了Encoder和Decoder，属于编解码器的一种
13type Serializer interface {
14  Encoder
15  Decoder
16}
17
18// 编解码器
19type Codec Serializer

 1// 该函数进行json和yaml两种格式的序列化器初始化
 2func newSerializersForScheme(scheme *runtime.Scheme, mf json.MetaFactory, options CodecFactoryOptions) []serializerType {
 3  jsonSerializer := json.NewSerializerWithOptions(
 4    mf, scheme, scheme,
 5    json.SerializerOptions{Yaml: false, Pretty: false, Strict: options.Strict},
 6  )
 7  jsonSerializerType := serializerType{
 8    AcceptContentTypes: []string{runtime.ContentTypeJSON},
 9    ContentType:        runtime.ContentTypeJSON,
10    FileExtensions:     []string{"json"},
11    EncodesAsText:      true,
12    Serializer:         jsonSerializer,
13
14    Framer:           json.Framer,
15    StreamSerializer: jsonSerializer,
16  }
17  if options.Pretty {
18    jsonSerializerType.PrettySerializer = json.NewSerializerWithOptions(
19      mf, scheme, scheme,
20      json.SerializerOptions{Yaml: false, Pretty: true, Strict: options.Strict},
21    )
22  }
23
24  yamlSerializer := json.NewSerializerWithOptions(
25    mf, scheme, scheme,
26    json.SerializerOptions{Yaml: true, Pretty: false, Strict: options.Strict},
27  )
28  protoSerializer := protobuf.NewSerializer(scheme, scheme)
29  protoRawSerializer := protobuf.NewRawSerializer(scheme, scheme)
30
31  serializers := []serializerType{
32    jsonSerializerType,
33    {
34      AcceptContentTypes: []string{runtime.ContentTypeYAML},
35      ContentType:        runtime.ContentTypeYAML,
36      FileExtensions:     []string{"yaml"},
37      EncodesAsText:      true,
38      Serializer:         yamlSerializer,
39    },
40    {
41      AcceptContentTypes: []string{runtime.ContentTypeProtobuf},
42      ContentType:        runtime.ContentTypeProtobuf,
43      FileExtensions:     []string{"pb"},
44      Serializer:         protoSerializer,
45
46      Framer:           protobuf.LengthDelimitedFramer,
47      StreamSerializer: protoRawSerializer,
48    },
49  }
50
51  for _, fn := range serializerExtensions {
52    if serializer, ok := fn(scheme); ok {
53      serializers = append(serializers, serializer)
54    }
55  }
56  return serializers
57}

 1// 转换函数结构
 2// a:转换源 b:转换目标 scope处理递归调用
 3type ConversionFunc func(a, b interface{}, scope Scope) error
 4
 5type ConversionFuncs struct {
 6  untyped map[typePair]ConversionFunc
 7}
 8
 9type Converter struct {
10  // 默认转换函数
11  conversionFuncs          ConversionFuncs
12  // 自动生成的转换函数
13  generatedConversionFuncs ConversionFuncs
14
15  // 忽略转换的字段
16  ignoredConversions        map[typePair]struct{}
17  ignoredUntypedConversions map[typePair]struct{}
18
19  // This is a map from a source field type and name, to a list of destination
20  // field type and name.
21  structFieldDests map[typeNamePair][]typeNamePair
22
23  // Allows for the opposite lookup of structFieldDests. So that SourceFromDest
24  // copy flag also works. So this is a map of destination field name, to potential
25  // source field name and type to look for.
26  structFieldSources map[typeNamePair][]typeNamePair
27
28  // Map from an input type to a function which can apply a key name mapping
29  inputFieldMappingFuncs map[reflect.Type]FieldMappingFunc
30
31  // Map from an input type to a set of default conversion flags.
32  inputDefaultFlags map[reflect.Type]FieldMatchingFlags
33
34  // If non-nil, will be called to print helpful debugging info. Quite verbose.
35  Debug DebugLogger
36
37  // 转换过程中获取资源种类名称
38  nameFunc func(t reflect.Type) string
39}