Documentation ¶
Index ¶
- Variables
- func KubeadmUpgradeTasks(runtime connector.Runtime, u *UpgradeKubeMaster) error
- func OverrideCoreDNSService(runtime connector.Runtime, kubeAction common.KubeAction) error
- func SetKubeletTasks(runtime connector.Runtime, kubeAction common.KubeAction) error
- func SyncKubeBinaries(runtime connector.Runtime, binariesMap map[string]*files.KubeBinary) error
- func SyncKubeConfigTask(runtime connector.Runtime, kubeAction common.KubeAction) error
- type AddWorkerLabel
- type CalculateNextVersion
- type ClusterIsExist
- type ClusterNotEqualDesiredVersion
- type CompareConfigAndClusterInfoModule
- type ConfigureKubernetes
- type ConfigureKubernetesModule
- type CopyKubeConfigForControlPlane
- type DeleteKubeNodeModule
- type DrainNode
- type EnableKubelet
- type EtcdSecurityEnhancemenAction
- type FindNode
- type GenerateKubeadmConfig
- type GenerateKubeletEnv
- type GetClusterStatus
- type InitKubernetesModule
- type InstallKubeBinariesModule
- type JoinNode
- type JoinNodesModule
- type KubeadmInit
- type KubeadmReset
- type KubeadmUpgrade
- type KubectlDeleteNode
- type KubernetesStatus
- func (k *KubernetesStatus) LoadKubeConfig(runtime connector.Runtime, kubeConf *common.KubeConf) error
- func (k *KubernetesStatus) SearchClusterInfo(runtime connector.Runtime) error
- func (k *KubernetesStatus) SearchJoinInfo(runtime connector.Runtime) error
- func (k *KubernetesStatus) SearchKubeConfig(runtime connector.Runtime) error
- func (k *KubernetesStatus) SearchNodesInfo(_ connector.Runtime) error
- func (k *KubernetesStatus) SearchVersion(runtime connector.Runtime) error
- type MasterSecurityEnhancemenAction
- type NoClusterInfo
- type NodeInCluster
- type NodesSecurityEnhancemenAction
- type NotEqualDesiredVersion
- type NotEqualPlanVersion
- type ProgressiveUpgradeModule
- type ReconfigureDNS
- type RemoveMasterTaint
- type ResetClusterModule
- type SaveKubeConfig
- type SaveKubeConfigModule
- type SecurityEnhancementModule
- type SetCurrentK8sVersion
- type SetUpgradePlan
- type SetUpgradePlanModule
- type StatusModule
- type SyncKubeBinary
- type SyncKubeConfigToWorker
- type SyncKubelet
- type UpgradeKubeMaster
- type UpgradeKubeWorker
- type UpgradeStep
Constants ¶
This section is empty.
Variables ¶
View Source
var UpgradeStepList = []UpgradeStep{ ToV121, ToV122, }
Functions ¶
func KubeadmUpgradeTasks ¶
func KubeadmUpgradeTasks(runtime connector.Runtime, u *UpgradeKubeMaster) error
func OverrideCoreDNSService ¶
func OverrideCoreDNSService(runtime connector.Runtime, kubeAction common.KubeAction) error
func SetKubeletTasks ¶
func SetKubeletTasks(runtime connector.Runtime, kubeAction common.KubeAction) error
func SyncKubeBinaries ¶
SyncKubeBinaries is used to sync kubernetes' binaries to each node.
func SyncKubeConfigTask ¶
func SyncKubeConfigTask(runtime connector.Runtime, kubeAction common.KubeAction) error
Types ¶
type AddWorkerLabel ¶
type AddWorkerLabel struct {
common.KubeAction
}
type CalculateNextVersion ¶
type CalculateNextVersion struct {
common.KubeAction
}
type ClusterIsExist ¶
type ClusterIsExist struct { common.KubePrepare Not bool }
type ClusterNotEqualDesiredVersion ¶
type ClusterNotEqualDesiredVersion struct {
common.KubePrepare
}
type CompareConfigAndClusterInfoModule ¶
type CompareConfigAndClusterInfoModule struct {
common.KubeModule
}
func (*CompareConfigAndClusterInfoModule) Init ¶
func (c *CompareConfigAndClusterInfoModule) Init()
type ConfigureKubernetes ¶
type ConfigureKubernetes struct {
common.KubeAction
}
type ConfigureKubernetesModule ¶
type ConfigureKubernetesModule struct {
common.KubeModule
}
func (*ConfigureKubernetesModule) Init ¶
func (c *ConfigureKubernetesModule) Init()
type CopyKubeConfigForControlPlane ¶
type CopyKubeConfigForControlPlane struct {
common.KubeAction
}
type DeleteKubeNodeModule ¶
type DeleteKubeNodeModule struct {
common.KubeModule
}
func (*DeleteKubeNodeModule) Init ¶
func (d *DeleteKubeNodeModule) Init()
type DrainNode ¶
type DrainNode struct {
common.KubeAction
}
type EnableKubelet ¶
type EnableKubelet struct {
common.KubeAction
}
type EtcdSecurityEnhancemenAction ¶
type EtcdSecurityEnhancemenAction struct { common.KubeAction ModuleName string }
type FindNode ¶
type FindNode struct {
common.KubeAction
}
type GenerateKubeadmConfig ¶
type GenerateKubeadmConfig struct { common.KubeAction IsInitConfiguration bool WithSecurityEnhancement bool }
type GenerateKubeletEnv ¶
type GenerateKubeletEnv struct {
common.KubeAction
}
type GetClusterStatus ¶
type GetClusterStatus struct {
common.KubeAction
}
type InitKubernetesModule ¶
type InitKubernetesModule struct {
common.KubeModule
}
func (*InitKubernetesModule) Init ¶
func (i *InitKubernetesModule) Init()
type InstallKubeBinariesModule ¶
type InstallKubeBinariesModule struct {
common.KubeModule
}
func (*InstallKubeBinariesModule) Init ¶
func (i *InstallKubeBinariesModule) Init()
type JoinNode ¶
type JoinNode struct {
common.KubeAction
}
type JoinNodesModule ¶
type JoinNodesModule struct {
common.KubeModule
}
func (*JoinNodesModule) Init ¶
func (j *JoinNodesModule) Init()
type KubeadmInit ¶
type KubeadmInit struct {
common.KubeAction
}
type KubeadmReset ¶
type KubeadmReset struct {
common.KubeAction
}
type KubeadmUpgrade ¶
type KubeadmUpgrade struct {
common.KubeAction
}
type KubectlDeleteNode ¶
type KubectlDeleteNode struct {
common.KubeAction
}
type KubernetesStatus ¶
type KubernetesStatus struct { Version string BootstrapToken string CertificateKey string ClusterInfo string KubeConfig string NodesInfo map[string]string }
func NewKubernetesStatus ¶
func NewKubernetesStatus() *KubernetesStatus
func (*KubernetesStatus) LoadKubeConfig ¶
func (*KubernetesStatus) SearchClusterInfo ¶
func (k *KubernetesStatus) SearchClusterInfo(runtime connector.Runtime) error
func (*KubernetesStatus) SearchJoinInfo ¶
func (k *KubernetesStatus) SearchJoinInfo(runtime connector.Runtime) error
func (*KubernetesStatus) SearchKubeConfig ¶
func (k *KubernetesStatus) SearchKubeConfig(runtime connector.Runtime) error
func (*KubernetesStatus) SearchNodesInfo ¶
func (k *KubernetesStatus) SearchNodesInfo(_ connector.Runtime) error
func (*KubernetesStatus) SearchVersion ¶
func (k *KubernetesStatus) SearchVersion(runtime connector.Runtime) error
type MasterSecurityEnhancemenAction ¶
type MasterSecurityEnhancemenAction struct { common.KubeAction ModuleName string }
type NoClusterInfo ¶
type NoClusterInfo struct {
common.KubePrepare
}
type NodeInCluster ¶
type NodeInCluster struct { common.KubePrepare Not bool }
type NodesSecurityEnhancemenAction ¶
type NodesSecurityEnhancemenAction struct { common.KubeAction ModuleName string }
type NotEqualDesiredVersion ¶
type NotEqualDesiredVersion struct {
common.KubePrepare
}
type NotEqualPlanVersion ¶
type NotEqualPlanVersion struct {
common.KubePrepare
}
type ProgressiveUpgradeModule ¶
type ProgressiveUpgradeModule struct { common.KubeModule Step UpgradeStep }
func (*ProgressiveUpgradeModule) Init ¶
func (p *ProgressiveUpgradeModule) Init()
func (*ProgressiveUpgradeModule) Until ¶
func (p *ProgressiveUpgradeModule) Until() (*bool, error)
type ReconfigureDNS ¶
type ReconfigureDNS struct { common.KubeAction ModuleName string }
type RemoveMasterTaint ¶
type RemoveMasterTaint struct {
common.KubeAction
}
type ResetClusterModule ¶
type ResetClusterModule struct {
common.KubeModule
}
func (*ResetClusterModule) Init ¶
func (r *ResetClusterModule) Init()
type SaveKubeConfig ¶
type SaveKubeConfig struct {
common.KubeAction
}
type SaveKubeConfigModule ¶
type SaveKubeConfigModule struct {
common.KubeModule
}
func (*SaveKubeConfigModule) Init ¶
func (s *SaveKubeConfigModule) Init()
type SecurityEnhancementModule ¶
type SecurityEnhancementModule struct { common.KubeModule Skip bool }
func (*SecurityEnhancementModule) Init ¶
func (s *SecurityEnhancementModule) Init()
func (*SecurityEnhancementModule) IsSkip ¶
func (s *SecurityEnhancementModule) IsSkip() bool
type SetCurrentK8sVersion ¶
type SetCurrentK8sVersion struct {
common.KubeAction
}
type SetUpgradePlan ¶
type SetUpgradePlan struct { common.KubeAction Step UpgradeStep }
type SetUpgradePlanModule ¶
type SetUpgradePlanModule struct { common.KubeModule Step UpgradeStep }
func (*SetUpgradePlanModule) Init ¶
func (s *SetUpgradePlanModule) Init()
type StatusModule ¶
type StatusModule struct {
common.KubeModule
}
func (*StatusModule) Init ¶
func (k *StatusModule) Init()
type SyncKubeBinary ¶
type SyncKubeBinary struct {
common.KubeAction
}
type SyncKubeConfigToWorker ¶
type SyncKubeConfigToWorker struct {
common.KubeAction
}
type SyncKubelet ¶
type SyncKubelet struct {
common.KubeAction
}
type UpgradeKubeMaster ¶
type UpgradeKubeMaster struct { common.KubeAction ModuleName string }
type UpgradeKubeWorker ¶
type UpgradeKubeWorker struct { common.KubeAction ModuleName string }
type UpgradeStep ¶
type UpgradeStep int
const ( ToV121 UpgradeStep = iota + 1 ToV122 )
func (UpgradeStep) String ¶
func (u UpgradeStep) String() string
Source Files ¶
Click to show internal directories.
Click to hide internal directories.