kubeadm

Documentation

Index

• Constants
• Variables
• func AddNeedUpgradeLabel(platformClient platformv1client.PlatformV1Interface, ...) error
• func ContainerLabelOfControlPlane(c *v1.Cluster, name string) string
• func Init(s ssh.Interface, kubeadmConfig *InitConfig, phase string, preActions ...string) error
• func Install(s ssh.Interface, option *Option) 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(c *v1.Cluster, s ssh.Interface) error
• func Reset(s ssh.Interface, phase string) error
• func RestartContainerByLabel(c *v1.Cluster, s ssh.Interface, label string) error
• func RestartControlPlane(c *v1.Cluster, 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 Option
• 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 ContainerLabelOfControlPlane

func ContainerLabelOfControlPlane(c *v1.Cluster, name string) string

func Init

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

func Install

func Install(s ssh.Interface, option *Option) 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(c *v1.Cluster, s ssh.Interface) error

func Reset

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

func RestartContainerByLabel

func RestartContainerByLabel(c *v1.Cluster, s ssh.Interface, label string) error

func RestartControlPlane

func RestartControlPlane(c *v1.Cluster, 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 Option

type Option struct {
	RuntimeType platformv1.ContainerRuntimeType
	Version     string
}

type UpgradeOption

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