type StaticPodPathManager … type KubeStaticPodPathManager … // NewKubeStaticPodPathManager creates a new instance of KubeStaticPodPathManager func NewKubeStaticPodPathManager(kubernetesDir, patchesDir, tempDir, backupDir, backupEtcdDir string, keepManifestDir, keepEtcdDir bool) StaticPodPathManager { … } // NewKubeStaticPodPathManagerUsingTempDirs creates a new instance of KubeStaticPodPathManager with temporary directories backing it func NewKubeStaticPodPathManagerUsingTempDirs(kubernetesDir, patchesDir string, saveManifestsDir, saveEtcdDir bool) (StaticPodPathManager, error) { … } // MoveFile should move a file from oldPath to newPath func (spm *KubeStaticPodPathManager) MoveFile(oldPath, newPath string) error { … } // KubernetesDir should point to the directory Kubernetes owns for storing various configuration files func (spm *KubeStaticPodPathManager) KubernetesDir() string { … } // PatchesDir should point to the folder where patches for components are stored func (spm *KubeStaticPodPathManager) PatchesDir() string { … } // RealManifestPath gets the file path for the component in the "real" static pod manifest directory used by the kubelet func (spm *KubeStaticPodPathManager) RealManifestPath(component string) string { … } // RealManifestDir should point to the static pod manifest directory used by the kubelet func (spm *KubeStaticPodPathManager) RealManifestDir() string { … } // TempManifestPath gets the file path for the component in the temporary directory created for generating new manifests for the upgrade func (spm *KubeStaticPodPathManager) TempManifestPath(component string) string { … } // TempManifestDir should point to the temporary directory created for generating new manifests for the upgrade func (spm *KubeStaticPodPathManager) TempManifestDir() string { … } // BackupManifestPath gets the file path for the component in the backup directory used for backing up manifests during the transition func (spm *KubeStaticPodPathManager) BackupManifestPath(component string) string { … } // BackupManifestDir should point to the backup directory used for backing up manifests during the transition func (spm *KubeStaticPodPathManager) BackupManifestDir() string { … } // BackupEtcdDir should point to the backup directory used for backing up manifests during the transition func (spm *KubeStaticPodPathManager) BackupEtcdDir() string { … } // CleanupDirs cleans up all temporary directories except those the user has requested to keep around func (spm *KubeStaticPodPathManager) CleanupDirs() error { … } func upgradeComponent(component string, certsRenewMgr *renewal.Manager, waiter apiclient.Waiter, pathMgr StaticPodPathManager, cfg *kubeadmapi.InitConfiguration, beforePodHash string, recoverManifests map[string]string) error { … } // performEtcdStaticPodUpgrade performs upgrade of etcd, it returns bool which indicates fatal error or not and the actual error. func performEtcdStaticPodUpgrade(certsRenewMgr *renewal.Manager, client clientset.Interface, waiter apiclient.Waiter, pathMgr StaticPodPathManager, cfg *kubeadmapi.InitConfiguration, recoverManifests map[string]string, oldEtcdClient, newEtcdClient etcdutil.ClusterInterrogator) (bool, error) { … } // StaticPodControlPlane upgrades a static pod-hosted control plane func StaticPodControlPlane(client clientset.Interface, waiter apiclient.Waiter, pathMgr StaticPodPathManager, cfg *kubeadmapi.InitConfiguration, etcdUpgrade, renewCerts bool, oldEtcdClient, newEtcdClient etcdutil.ClusterInterrogator) error { … } // rollbackOldManifests rolls back the backed-up manifests if something went wrong. // It always returns an error to the caller. func rollbackOldManifests(oldManifests map[string]string, origErr error, pathMgr StaticPodPathManager, restoreEtcd bool) error { … } // rollbackEtcdData rolls back the content of etcd folder if something went wrong. // When the folder contents are successfully rolled back, nil is returned, otherwise an error is returned. func rollbackEtcdData(cfg *kubeadmapi.InitConfiguration, pathMgr StaticPodPathManager) error { … } // renewCertsByComponent takes charge of renewing certificates used by a specific component before // the static pod of the component is upgraded func renewCertsByComponent(cfg *kubeadmapi.InitConfiguration, component string, certsRenewMgr *renewal.Manager) error { … } // GetPathManagerForUpgrade returns a path manager properly configured for the given InitConfiguration. func GetPathManagerForUpgrade(kubernetesDir, patchesDir string, internalcfg *kubeadmapi.InitConfiguration, etcdUpgrade bool) (StaticPodPathManager, error) { … } // PerformStaticPodUpgrade performs the upgrade of the control plane components for a static pod hosted cluster func PerformStaticPodUpgrade(client clientset.Interface, waiter apiclient.Waiter, internalcfg *kubeadmapi.InitConfiguration, etcdUpgrade, renewCerts bool, patchesDir string) error { … } // DryRunStaticPodUpgrade fakes an upgrade of the control plane func DryRunStaticPodUpgrade(patchesDir string, internalcfg *kubeadmapi.InitConfiguration) error { … } // GetEtcdImageTagFromStaticPod returns the image tag of the local etcd static pod func GetEtcdImageTagFromStaticPod(manifestDir string) (string, error) { … } // convertImageTagMetadataToSemver converts imagetag in the format of semver_metadata to semver+metadata func convertImageTagMetadataToSemver(tag string) string { … }
Codebase Browser
kubernetes