kubeadm

Documentation

Index

• Constants
• Variables
• func AddNeedUpgradeLabel(platformClient platformv1client.PlatformV1Interface, ...) error
• func DockerFilterForControlPlane(name string) string
• func Init(s ssh.Interface, kubeadmConfig *InitConfig, phase string, preActions ...string) error
• func Install(s ssh.Interface, version string) error
• func Join(s ssh.Interface, config *kubeadmv1beta2.JoinConfiguration, phase string, ...) error
• func MarkNextUpgradeWorkerNode(client kubernetes.Interface, ...) error
• func MarshalToYAML(obj runtime.Object) ([]byte, error)
• func RemoveUpgradeLabel(platformClient platformv1client.PlatformV1Interface, ...) error
• func RenewCerts(s ssh.Interface) error
• func Reset(s ssh.Interface, phase string) error
• func RestartContainerByFilter(s ssh.Interface, filter string) error
• func RestartControlPlane(s ssh.Interface) error
• func UpgradeNode(s ssh.Interface, client kubernetes.Interface, ...) (upgraded bool, err error)
• type InitConfig
  • func (c *InitConfig) Marshal() ([]byte, error)
• type NodeRole
• type UpgradeOption

Constants

const (
	NodeRoleMaster = NodeRole("Master")
	NodeRoleWorker = NodeRole("Worker")
)

const (

	// WillUpgrade is value of label platform.tkestack.io/need-upgrade
	// machines with this value will upgrade it's node automatically one by one
	WillUpgrade = "willUpgrade"
)

Variables

var AddToScheme = localSchemeBuilder.AddToScheme

var Codecs = serializer.NewCodecFactory(Scheme)

var Scheme = runtime.NewScheme()

Functions

func AddNeedUpgradeLabel

func AddNeedUpgradeLabel(platformClient platformv1client.PlatformV1Interface, clusterName, labelValue string) error

func DockerFilterForControlPlane

func DockerFilterForControlPlane(name string) string

func Init

func Init(s ssh.Interface, kubeadmConfig *InitConfig, phase string, preActions ...string) error

func Install

func Install(s ssh.Interface, version string) error

func Join

func Join(s ssh.Interface, config *kubeadmv1beta2.JoinConfiguration, phase string, endPointIPs []string) error

func MarkNextUpgradeWorkerNode

func MarkNextUpgradeWorkerNode(client kubernetes.Interface, platformClient platformv1client.PlatformV1Interface, version, clusterName string) error

markNextUpgradeWorkerNode marks next wokrer node to be upgraded.

func MarshalToYAML

func MarshalToYAML(obj runtime.Object) ([]byte, error)

MarshalToYaml marshals an object into yaml.

func RemoveUpgradeLabel

func RemoveUpgradeLabel(platformClient platformv1client.PlatformV1Interface, machine *platformv1.Machine) error

func RenewCerts

func RenewCerts(s ssh.Interface) error

func Reset

func Reset(s ssh.Interface, phase string) error

func RestartContainerByFilter

func RestartContainerByFilter(s ssh.Interface, filter string) error

func RestartControlPlane

func RestartControlPlane(s ssh.Interface) error

func UpgradeNode

func UpgradeNode(s ssh.Interface, client kubernetes.Interface, platformClient platformv1client.PlatformV1Interface, logger log.Logger, cluster *v1.Cluster, option UpgradeOption) (upgraded bool, err error)

UpgradeNode upgrades node by kubeadm. Refer: https://kubernetes.io/docs/tasks/administer-cluster/kubeadm/kubeadm-upgrade/

Types

type InitConfig

type InitConfig struct {
	InitConfiguration      *kubeadmv1beta2.InitConfiguration
	ClusterConfiguration   *kubeadmv1beta2.ClusterConfiguration
	KubeletConfiguration   *kubeletv1beta1.KubeletConfiguration
	KubeProxyConfiguration *kubeproxyv1alpha1.KubeProxyConfiguration
}

func (*InitConfig) Marshal

func (c *InitConfig) Marshal() ([]byte, error)

type NodeRole

type NodeRole string

type UpgradeOption

type UpgradeOption struct {
	MachineName            string
	BootstrapNode          bool
	MachineIP              string
	NodeRole               NodeRole
	Version                string
	MaxUnready             *intstr.IntOrString
	DrainNodeBeforeUpgrade *bool
}