Learning: k8s 散解(WIP)
输入“/”快速插入内容
Learning: k8s 散解(WIP)
Learning: k8s 散解(WIP)
飞书用户4096月22日修改
•
Docker 和 containerd的关系：docker是汽车，containerd是发动机引擎（containerd专注于容器运行时、但不只专注与k8s(cri), 还有其他的容器编排引擎，比如mesos）
•
Pause容器：
◦
为什么叫pause容器？因为这个容器的主命令是for (;;) pause(); pause() 是Linux系统调用，其作用是挂起进程直至收到信号。
◦
作用：pod先启动pause容器，完成net/ipc/pid/uts namespace的设置，再启动自定义容器，并将容器加入对应的网络命名空间，使得同个pod共享网络命名空间。（为什么不把第一个自定义容器作为网络命名空间呢？因为存在init容器）
◦
默认情况下，kubernetes同一pod内的容器不共享进程命名空间
•
Uts namespace：隔离hostname、domainname, 这个domainname不知道是啥，先不管。
•
Ipc namespace: linux的IPC Namespace主要针对消息队列（Message queues）、信号量（Semaphore）、共享内存（Share Memory），其他的ipc方式不影响。
•
三种容器探针：Liveness, Readiness and Startup Probes
◦
Liveness存活探针：如果探针反复3次不通过，容器会重启。Liveness探针和readiness探针是并列的，没有顺序关系。
◦
Readiness就绪探针: 如果探针不通过，pod是unready的状态，被移出service。注意就绪探针会在pod的生命周期内持续周期运行，不是运行成功就结束了。Readiness probes run on the container during its whole lifecycle.
◦
Startup启动探针: 检查pod的启动，在startup成功之前 readiness/liveness不会启动，避免一些慢启动容器受到存活探针的影响没法正常启动。
•
pod状态（phase字段）：
◦
Pending、Running、Failed、Succeeded、Unknown
◦
只要有一个容器是running，那pod的phase就是running
•
pod状况（PodCondition字段）：
◦
PodScheduled、PodReadyToStartContainers、Initialized、ContainersReady、Ready、DisruptionTarget、PodResizePending、PodResizeInProgress
•
k8s 临时容器：kubectl debug $pod -it --image=busybox 在pod里创建一个临时容器用于调试，可以验证网络可达性之类的。
•
Informer 自定义索引
◦
加索引：podInformer.AddIndexers
◦
使用索引：podIndexer.ByIndex
代码块
// AddPodControllerUIDIndexer adds an indexer for Pod's controllerRef.UID to the given PodInformer.
// This indexer is used to efficiently look up pods by their ControllerRef.UID
func AddPodControllerUIDIndexer(podInformer cache.SharedIndexInformer) error {
if _, exists := podInformer.GetIndexer().GetIndexers()[PodControllerUIDIndex]; exists {
// indexer already exists, do nothing
return nil
}
return podInformer.AddIndexers(cache.Indexers{
PodControllerUIDIndex: func(obj interface{}) ([]string, error) {
pod, ok := obj.(*v1.Pod)
if !ok {
return nil, nil
}
// Get the ControllerRef of the Pod to check if it's managed by a controller
if ref := metav1.GetControllerOf(pod); ref != nil {
return []string{string(ref.UID)}, nil
}
// If the Pod has no controller (i.e., it's orphaned), index it with the OrphanPodIndexKey
// This helps identify orphan pods for reconciliation and adoption by controllers
return []string{OrphanPodIndexKey}, nil
},
})
}
// getRSPods returns the Pods that a given RS should manage.
func (rsc *ReplicaSetController) getRSPods(rs *apps.ReplicaSet) ([]*v1.Pod, error) {
// Iterate over two keys:
// The UID of the RS, which identifies Pods that are controlled by the RS.
// The OrphanPodIndexKey, which helps identify orphaned Pods that are not currently managed by any controller,
// but may be adopted later on if they have matching labels with the ReplicaSet.
podsForRS := []*v1.Pod{}
for _, key := range []string{string(rs.UID), controller.OrphanPodIndexKey} {
podObjs, err := rsc.podIndexer.ByIndex(controller.PodControllerUIDIndex, key)
if err != nil {
return nil, err
}
for _, obj := range podObjs {
pod, ok := obj.(*v1.Pod)
if !ok {
utilruntime.HandleError(fmt.Errorf("unexpected object type in pod indexer: %v", obj))
continue
}
podsForRS = append(podsForRS, pod)
}
}
return podsForRS, nil
}