123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129 |
- package pod
- import (
- "k8s.io/api/core/v1"
- "k8s.io/apimachinery/pkg/api/errors"
- metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
- "k8s.io/apimachinery/pkg/types"
- clientset "k8s.io/client-go/kubernetes"
- "k8s.io/klog"
- kubecontainer "k8s.io/kubernetes/pkg/kubelet/container"
- kubetypes "k8s.io/kubernetes/pkg/kubelet/types"
- )
- type MirrorClient interface {
-
-
-
-
- CreateMirrorPod(pod *v1.Pod) error
-
-
- DeleteMirrorPod(podFullName string, uid *types.UID) (bool, error)
- }
- type basicMirrorClient struct {
- apiserverClient clientset.Interface
- }
- func NewBasicMirrorClient(apiserverClient clientset.Interface) MirrorClient {
- return &basicMirrorClient{apiserverClient: apiserverClient}
- }
- func (mc *basicMirrorClient) CreateMirrorPod(pod *v1.Pod) error {
- if mc.apiserverClient == nil {
- return nil
- }
-
- copyPod := *pod
- copyPod.Annotations = make(map[string]string)
- for k, v := range pod.Annotations {
- copyPod.Annotations[k] = v
- }
- hash := getPodHash(pod)
- copyPod.Annotations[kubetypes.ConfigMirrorAnnotationKey] = hash
- apiPod, err := mc.apiserverClient.CoreV1().Pods(copyPod.Namespace).Create(©Pod)
- if err != nil && errors.IsAlreadyExists(err) {
-
- if h, ok := apiPod.Annotations[kubetypes.ConfigMirrorAnnotationKey]; ok && h == hash {
- return nil
- }
- }
- return err
- }
- func (mc *basicMirrorClient) DeleteMirrorPod(podFullName string, uid *types.UID) (bool, error) {
- if mc.apiserverClient == nil {
- return false, nil
- }
- name, namespace, err := kubecontainer.ParsePodFullName(podFullName)
- if err != nil {
- klog.Errorf("Failed to parse a pod full name %q", podFullName)
- return false, err
- }
- klog.V(2).Infof("Deleting a mirror pod %q (uid %#v)", podFullName, uid)
- var GracePeriodSeconds int64
- GracePeriodSeconds = 0
- if err := mc.apiserverClient.CoreV1().Pods(namespace).Delete(name, &metav1.DeleteOptions{GracePeriodSeconds: &GracePeriodSeconds, Preconditions: &metav1.Preconditions{UID: uid}}); err != nil {
-
- if !(errors.IsNotFound(err) || errors.IsConflict(err)) {
-
-
- klog.Errorf("Failed deleting a mirror pod %q: %v", podFullName, err)
- }
- return false, nil
- }
- return true, nil
- }
- func IsStaticPod(pod *v1.Pod) bool {
- source, err := kubetypes.GetPodSource(pod)
- return err == nil && source != kubetypes.ApiserverSource
- }
- func IsMirrorPod(pod *v1.Pod) bool {
- _, ok := pod.Annotations[kubetypes.ConfigMirrorAnnotationKey]
- return ok
- }
- func getHashFromMirrorPod(pod *v1.Pod) (string, bool) {
- hash, ok := pod.Annotations[kubetypes.ConfigMirrorAnnotationKey]
- return hash, ok
- }
- func getPodHash(pod *v1.Pod) string {
-
- return pod.Annotations[kubetypes.ConfigHashAnnotationKey]
- }
|