nodeadm

Documentation

Index

• func RebootInstance(ctx context.Context, runner commands.RemoteCommandRunner, instanceIP string) error
• func RunLogCollector(ctx context.Context, runner commands.RemoteCommandRunner, ...) error
• func RunNodeadmUninstall(ctx context.Context, runner commands.RemoteCommandRunner, instanceIP string) error
• func RunNodeadmUpgrade(ctx context.Context, runner commands.RemoteCommandRunner, ...) error
• type CleanNode
  • func (u CleanNode) Run(ctx context.Context) error
• type UninstallVerifier
• type UpgradeNode
  • func (u UpgradeNode) Run(ctx context.Context) error

Functions

func RebootInstance

func RebootInstance(ctx context.Context, runner commands.RemoteCommandRunner, instanceIP string) error

func RunLogCollector

func RunLogCollector(ctx context.Context, runner commands.RemoteCommandRunner, instanceIP, logBundleUrl string) error

func RunNodeadmUninstall

func RunNodeadmUninstall(ctx context.Context, runner commands.RemoteCommandRunner, instanceIP string) error

func RunNodeadmUpgrade

func RunNodeadmUpgrade(ctx context.Context, runner commands.RemoteCommandRunner, instanceIP, kubernetesVersion string) error

Types

type CleanNode

type CleanNode struct {
	K8s                 *clientgo.Clientset
	RemoteCommandRunner commands.RemoteCommandRunner
	Verifier            UninstallVerifier
	Logger              logr.Logger

	NodeIP string
}

CleanNode runs the process to unregister a node from the cluster and uninstall all the installed kubernetes dependencies.

func (CleanNode) Run

func (u CleanNode) Run(ctx context.Context) error

type UninstallVerifier

type UninstallVerifier interface {
	VerifyUninstall(ctx context.Context, nodeName string) error
}

UninstallVerifier checks if nodeadm uninstall process was successful in a node.

type UpgradeNode

type UpgradeNode struct {
	K8s                 *clientgo.Clientset
	RemoteCommandRunner commands.RemoteCommandRunner
	Logger              logr.Logger

	NodeIP           string
	TargetK8sVersion string
}

UpgradeNode runs the process to upgrade the k8s version in a node in the cluster. This assumes the current node's version meets the version skew policy and it can actually be upgraded to the target version.

func (UpgradeNode) Run

func (u UpgradeNode) Run(ctx context.Context) error