Versions in this module Expand all Collapse all v1 v1.16.3 Oct 23, 2019 Changes in this version + const MaximumAllowedMinorVersionDowngradeSkew + const MaximumAllowedMinorVersionKubeletSkew + const MaximumAllowedMinorVersionUpgradeSkew + const UpgradeManifestTimeout + func CheckClusterHealth(client clientset.Interface, ignoreChecksErrors sets.String) error + func DryRunStaticPodUpgrade(kustomizeDir string, internalcfg *kubeadmapi.InitConfiguration) error + func GetKubeletDir(dryRun bool) (string, error) + func IsControlPlaneSelfHosted(client clientset.Interface) bool + func PerformPostUpgradeTasks(client clientset.Interface, cfg *kubeadmapi.InitConfiguration, ...) error + func PerformStaticPodUpgrade(client clientset.Interface, waiter apiclient.Waiter, ...) error + func PrepullImagesInParallel(kubePrepuller Prepuller, timeout time.Duration, componentsToPrepull []string) error + func RunCoreDNSMigrationCheck(client clientset.Interface, ignorePreflightErrors sets.String, ...) error + func StaticPodControlPlane(client clientset.Interface, waiter apiclient.Waiter, ...) error + type ClusterState struct + DNSType kubeadmapi.DNSAddOnType + DNSVersion string + EtcdVersion string + KubeVersion string + KubeadmVersion string + KubeletVersions map[string]uint16 + type CoreDNSCheck struct + func (c CoreDNSCheck) Check() (warnings, errors []error) + func (c CoreDNSCheck) Name() string + type DaemonSetPrepuller struct + func NewDaemonSetPrepuller(client clientset.Interface, waiter apiclient.Waiter, ...) *DaemonSetPrepuller + func (d *DaemonSetPrepuller) CreateFunc(component string) error + func (d *DaemonSetPrepuller) DeleteFunc(component string) error + func (d *DaemonSetPrepuller) WaitFunc(component string) + type KubeStaticPodPathManager struct + func (spm *KubeStaticPodPathManager) BackupEtcdDir() string + func (spm *KubeStaticPodPathManager) BackupManifestDir() string + func (spm *KubeStaticPodPathManager) BackupManifestPath(component string) string + func (spm *KubeStaticPodPathManager) CleanupDirs() error + func (spm *KubeStaticPodPathManager) KubernetesDir() string + func (spm *KubeStaticPodPathManager) KustomizeDir() string + func (spm *KubeStaticPodPathManager) MoveFile(oldPath, newPath string) error + func (spm *KubeStaticPodPathManager) RealManifestDir() string + func (spm *KubeStaticPodPathManager) RealManifestPath(component string) string + func (spm *KubeStaticPodPathManager) TempManifestDir() string + func (spm *KubeStaticPodPathManager) TempManifestPath(component string) string + type KubeVersionGetter struct + func (g *KubeVersionGetter) ClusterVersion() (string, *versionutil.Version, error) + func (g *KubeVersionGetter) KubeadmVersion() (string, *versionutil.Version, error) + func (g *KubeVersionGetter) KubeletVersions() (map[string]uint16, error) + func (g *KubeVersionGetter) VersionFromCILabel(ciVersionLabel, description string) (string, *versionutil.Version, error) + type OfflineVersionGetter struct + func (o *OfflineVersionGetter) VersionFromCILabel(ciVersionLabel, description string) (string, *versionutil.Version, error) + type Prepuller interface + CreateFunc func(string) error + DeleteFunc func(string) error + WaitFunc func(string) + type StaticPodPathManager interface + BackupEtcdDir func() string + BackupManifestDir func() string + BackupManifestPath func(component string) string + CleanupDirs func() error + KubernetesDir func() string + KustomizeDir func() string + MoveFile func(oldPath, newPath string) error + RealManifestDir func() string + RealManifestPath func(component string) string + TempManifestDir func() string + TempManifestPath func(component string) string + func GetPathManagerForUpgrade(kubernetesDir, kustomizeDir string, internalcfg *kubeadmapi.InitConfiguration, ...) (StaticPodPathManager, error) + func NewKubeStaticPodPathManager(kubernetesDir, kustomizeDir, tempDir, backupDir, backupEtcdDir string, ...) StaticPodPathManager + func NewKubeStaticPodPathManagerUsingTempDirs(kubernetesDir, kustomizeDir string, saveManifestsDir, saveEtcdDir bool) (StaticPodPathManager, error) + type Upgrade struct + After ClusterState + Before ClusterState + Description string + func GetAvailableUpgrades(versionGetterImpl VersionGetter, ...) ([]Upgrade, error) + func (u *Upgrade) CanUpgradeEtcd() bool + func (u *Upgrade) CanUpgradeKubelets() bool + type VersionGetter interface + ClusterVersion func() (string, *versionutil.Version, error) + KubeadmVersion func() (string, *versionutil.Version, error) + KubeletVersions func() (map[string]uint16, error) + VersionFromCILabel func(string, string) (string, *versionutil.Version, error) + func NewKubeVersionGetter(client clientset.Interface, writer io.Writer) VersionGetter + func NewOfflineVersionGetter(versionGetter VersionGetter, version string) VersionGetter + type VersionSkewPolicyErrors struct + Mandatory []error + Skippable []error + func EnforceVersionPolicies(versionGetter VersionGetter, newK8sVersionStr string, ...) *VersionSkewPolicyErrors