kubernetes

package
v3.1.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Apr 12, 2024 License: Apache-2.0 Imports: 32 Imported by: 7

Documentation

Index

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 SetKubeletTasks 

func SetKubeletTasks(runtime connector.Runtime, kubeAction common.KubeAction) error

func SyncKubeBinaries 

func SyncKubeBinaries(i *SyncKubeBinary, runtime connector.Runtime, binariesMap map[string]*files.KubeBinary) error

SyncKubeBinaries is used to sync kubernetes' binaries to each node.

Types

type AddWorkerLabel 

type AddWorkerLabel struct {
	common.KubeAction
}

func (*AddWorkerLabel) Execute 

func (a *AddWorkerLabel) Execute(runtime connector.Runtime) error

type CalculateNextVersion 

type CalculateNextVersion struct {
	common.KubeAction
}

func (*CalculateNextVersion) Execute 

func (c *CalculateNextVersion) Execute(_ connector.Runtime) error

type ChmodKubelet added in v3.0.8 

type ChmodKubelet struct {
	common.KubeAction
}

func (*ChmodKubelet) Execute added in v3.0.8 

func (c *ChmodKubelet) Execute(runtime connector.Runtime) error

type ClusterIsExist 

type ClusterIsExist struct {
	common.KubePrepare
	Not bool
}

func (*ClusterIsExist) PreCheck 

func (c *ClusterIsExist) PreCheck(_ connector.Runtime) (bool, error)

type ClusterNotEqualDesiredVersion 

type ClusterNotEqualDesiredVersion struct {
	common.KubePrepare
}

func (*ClusterNotEqualDesiredVersion) PreCheck 

func (c *ClusterNotEqualDesiredVersion) PreCheck(runtime connector.Runtime) (bool, error)

type CompareConfigAndClusterInfoModule 

type CompareConfigAndClusterInfoModule struct {
	common.KubeModule
}

func (*CompareConfigAndClusterInfoModule) Init 

func (c *CompareConfigAndClusterInfoModule) Init()

type ConfigureKubernetes 

type ConfigureKubernetes struct {
	common.KubeAction
}

func (*ConfigureKubernetes) Execute 

func (c *ConfigureKubernetes) Execute(runtime connector.Runtime) error

type ConfigureKubernetesModule 

type ConfigureKubernetesModule struct {
	common.KubeModule
}

func (*ConfigureKubernetesModule) Init 

func (c *ConfigureKubernetesModule) Init()

type CopyKubeConfigForControlPlane 

type CopyKubeConfigForControlPlane struct {
	common.KubeAction
}

func (*CopyKubeConfigForControlPlane) Execute 

func (c *CopyKubeConfigForControlPlane) Execute(runtime connector.Runtime) error

type DeleteKubeNodeModule 

type DeleteKubeNodeModule struct {
	common.KubeModule
}

func (*DeleteKubeNodeModule) Init 

func (d *DeleteKubeNodeModule) Init()

type DrainNode 

type DrainNode struct {
	common.KubeAction
}

func (*DrainNode) Execute 

func (d *DrainNode) Execute(runtime connector.Runtime) error

type EnableKubelet 

type EnableKubelet struct {
	common.KubeAction
}

func (*EnableKubelet) Execute 

func (e *EnableKubelet) Execute(runtime connector.Runtime) error

type EtcdSecurityEnhancemenAction 

type EtcdSecurityEnhancemenAction struct {
	common.KubeAction
	ModuleName string
}

func (*EtcdSecurityEnhancemenAction) Execute 

func (s *EtcdSecurityEnhancemenAction) Execute(runtime connector.Runtime) error

type FilterFirstMaster added in v3.1.0 

type FilterFirstMaster struct {
	common.KubeAction
}

func (*FilterFirstMaster) Execute added in v3.1.0 

func (f *FilterFirstMaster) Execute(runtime connector.Runtime) error

type FindNode 

type FindNode struct {
	common.KubeAction
}

func (*FindNode) Execute 

func (f *FindNode) Execute(runtime connector.Runtime) error

type GenerateKubeadmConfig 

type GenerateKubeadmConfig struct {
	common.KubeAction
	IsInitConfiguration     bool
	WithSecurityEnhancement bool
}

func (*GenerateKubeadmConfig) Execute 

func (g *GenerateKubeadmConfig) Execute(runtime connector.Runtime) error

type GenerateKubeletEnv 

type GenerateKubeletEnv struct {
	common.KubeAction
}

func (*GenerateKubeletEnv) Execute 

func (g *GenerateKubeletEnv) Execute(runtime connector.Runtime) error

type GetClusterStatus 

type GetClusterStatus struct {
	common.KubeAction
}

func (*GetClusterStatus) Execute 

func (g *GetClusterStatus) Execute(runtime connector.Runtime) error

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
}

func (*JoinNode) Execute 

func (j *JoinNode) Execute(runtime connector.Runtime) error

type JoinNodesModule 

type JoinNodesModule struct {
	common.KubeModule
}

func (*JoinNodesModule) Init 

func (j *JoinNodesModule) Init()

type KubeadmInit 

type KubeadmInit struct {
	common.KubeAction
}

func (*KubeadmInit) Execute 

func (k *KubeadmInit) Execute(runtime connector.Runtime) error

type KubeadmReset 

type KubeadmReset struct {
	common.KubeAction
}

func (*KubeadmReset) Execute 

func (k *KubeadmReset) Execute(runtime connector.Runtime) error

type KubeadmUpgrade 

type KubeadmUpgrade struct {
	common.KubeAction
}

func (*KubeadmUpgrade) Execute 

func (k *KubeadmUpgrade) Execute(runtime connector.Runtime) error

type KubectlDeleteNode 

type KubectlDeleteNode struct {
	common.KubeAction
}

func (*KubectlDeleteNode) Execute 

func (k *KubectlDeleteNode) Execute(runtime connector.Runtime) error

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 (k *KubernetesStatus) LoadKubeConfig(runtime connector.Runtime, kubeConf *common.KubeConf) error

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
}

func (*MasterSecurityEnhancemenAction) Execute 

func (k *MasterSecurityEnhancemenAction) Execute(runtime connector.Runtime) error

type NoClusterInfo 

type NoClusterInfo struct {
	common.KubePrepare
}

func (*NoClusterInfo) PreCheck 

func (n *NoClusterInfo) PreCheck(_ connector.Runtime) (bool, error)

type NodeInCluster 

type NodeInCluster struct {
	common.KubePrepare
	Not bool
}

func (*NodeInCluster) PreCheck 

func (n *NodeInCluster) PreCheck(runtime connector.Runtime) (bool, error)

type NodesSecurityEnhancemenAction 

type NodesSecurityEnhancemenAction struct {
	common.KubeAction
	ModuleName string
}

func (*NodesSecurityEnhancemenAction) Execute 

func (n *NodesSecurityEnhancemenAction) Execute(runtime connector.Runtime) error

type NotEqualDesiredVersion 

type NotEqualDesiredVersion struct {
	common.KubePrepare
}

func (*NotEqualDesiredVersion) PreCheck 

func (n *NotEqualDesiredVersion) PreCheck(runtime connector.Runtime) (bool, error)

type NotEqualPlanVersion 

type NotEqualPlanVersion struct {
	common.KubePrepare
}

func (*NotEqualPlanVersion) PreCheck 

func (n *NotEqualPlanVersion) PreCheck(runtime connector.Runtime) (bool, error)

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 RemoveMasterTaint 

type RemoveMasterTaint struct {
	common.KubeAction
}

func (*RemoveMasterTaint) Execute 

func (r *RemoveMasterTaint) Execute(runtime connector.Runtime) error

type ResetClusterModule 

type ResetClusterModule struct {
	common.KubeModule
}

func (*ResetClusterModule) Init 

func (r *ResetClusterModule) Init()

type RestartKubelet added in v3.1.0 

type RestartKubelet struct {
	common.KubeAction
	ModuleName string
}

func (*RestartKubelet) Execute added in v3.1.0 

func (r *RestartKubelet) Execute(runtime connector.Runtime) error

type RestartKubeletModule added in v3.1.0 

type RestartKubeletModule struct {
	common.KubeModule
}

type SaveKubeConfig 

type SaveKubeConfig struct {
	common.KubeAction
}

func (*SaveKubeConfig) Execute 

func (s *SaveKubeConfig) Execute(runtime connector.Runtime) error

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
}

func (*SetCurrentK8sVersion) Execute 

func (s *SetCurrentK8sVersion) Execute(_ connector.Runtime) error

type SetUpgradePlan 

type SetUpgradePlan struct {
	common.KubeAction
	Step UpgradeStep
}

func (*SetUpgradePlan) Execute 

func (s *SetUpgradePlan) Execute(_ connector.Runtime) error

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
}

func (*SyncKubeBinary) Execute 

func (i *SyncKubeBinary) Execute(runtime connector.Runtime) error

type UpgradeKubeMaster 

type UpgradeKubeMaster struct {
	common.KubeAction
	ModuleName string
}

func (*UpgradeKubeMaster) Execute 

func (u *UpgradeKubeMaster) Execute(runtime connector.Runtime) error

type UpgradeKubeWorker 

type UpgradeKubeWorker struct {
	common.KubeAction
	ModuleName string
}

func (*UpgradeKubeWorker) Execute 

func (u *UpgradeKubeWorker) Execute(runtime connector.Runtime) error

type UpgradeStep 

type UpgradeStep int
const (
	ToV121 UpgradeStep = iota + 1
	ToV122
)

func (UpgradeStep) String 

func (u UpgradeStep) String() string

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.