kubeadm

Documentation

Index

• Constants
• Variables
• func DockerFilterForControlPlane(name string) string
• func Init(s ssh.Interface, kubeadmConfig *InitConfig, phase 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 RenewCerts(s ssh.Interface) 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")
)

Variables

var AddToScheme = localSchemeBuilder.AddToScheme

var Codecs = serializer.NewCodecFactory(Scheme)

var Scheme = runtime.NewScheme()

Functions

func DockerFilterForControlPlane

func DockerFilterForControlPlane(name string) string

func Init

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

func Install

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

func Join

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

func MarkNextUpgradeWorkerNode

func MarkNextUpgradeWorkerNode(client kubernetes.Interface, platformClient platformv1client.PlatformV1Interface, version 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 RenewCerts

func RenewCerts(s ssh.Interface) 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, 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
}