kubeadm

Documentation

Index

• Variables
• func StopKubernetes(runner command.Runner, cr cruntime.Manager)
• type Bootstrapper
  • func NewBootstrapper(_ libmachine.API, cc config.ClusterConfig, r command.Runner) (*Bootstrapper, error)
  • func (k *Bootstrapper) DeleteCluster(k8s config.KubernetesConfig) error
  • func (k *Bootstrapper) GenerateToken(cc config.ClusterConfig) (string, error)
  • func (k *Bootstrapper) GetAPIServerStatus(hostname string, port int) (string, error)
  • func (k *Bootstrapper) JoinCluster(cc config.ClusterConfig, n config.Node, joinCmd string) error
  • func (k *Bootstrapper) LabelAndUntaintNode(cfg config.ClusterConfig, n config.Node) error
  • func (k *Bootstrapper) LogCommands(cfg config.ClusterConfig, o bootstrapper.LogOptions) map[string]string
  • func (k *Bootstrapper) SetupCerts(k8s config.ClusterConfig, n config.Node, pcpCmd cruntime.CommandRunner) error
  • func (k *Bootstrapper) StartCluster(cfg config.ClusterConfig) error
  • func (k *Bootstrapper) UpdateCluster(cfg config.ClusterConfig) error
  • func (k *Bootstrapper) UpdateNode(cfg config.ClusterConfig, n config.Node, r cruntime.Manager) error
  • func (k *Bootstrapper) WaitForNode(cfg config.ClusterConfig, n config.Node, timeout time.Duration) error
• type FailFastError
  • func (f *FailFastError) Error() string

Variables

var ErrInitTimedout = fmt.Errorf("kubeadm init timed out in %d minutes", initTimeoutMinutes)

ErrInitTimedout is thrown if kubeadm init takes longer than max time allowed

var ErrNoExecLinux = &FailFastError{errors.New("mounted kubeadm binary is not executable")}

ErrNoExecLinux is thrown on linux when the kubeadm binaries are mounted in a noexec volume on Linux as seen in https://github.com/kubernetes/minikube/issues/8327#issuecomment-651288459 this error could be seen on docker/podman or none driver.

Functions

func StopKubernetes

func StopKubernetes(runner command.Runner, cr cruntime.Manager)

StopKubernetes attempts to stop existing kubernetes.

Types

type Bootstrapper

type Bootstrapper struct {
	// contains filtered or unexported fields
}

Bootstrapper is a bootstrapper using kubeadm

func NewBootstrapper

func NewBootstrapper(_ libmachine.API, cc config.ClusterConfig, r command.Runner) (*Bootstrapper, error)

NewBootstrapper creates a new kubeadm.Bootstrapper

func (*Bootstrapper) DeleteCluster

func (k *Bootstrapper) DeleteCluster(k8s config.KubernetesConfig) error

DeleteCluster removes the components that were started earlier

func (*Bootstrapper) GenerateToken

func (k *Bootstrapper) GenerateToken(cc config.ClusterConfig) (string, error)

GenerateToken creates a token and returns the appropriate kubeadm join command to run, or the already existing token

func (*Bootstrapper) GetAPIServerStatus

func (k *Bootstrapper) GetAPIServerStatus(hostname string, port int) (string, error)

GetAPIServerStatus returns the api-server status

func (*Bootstrapper) JoinCluster

func (k *Bootstrapper) JoinCluster(cc config.ClusterConfig, n config.Node, joinCmd string) error

JoinCluster adds new node to an existing cluster.

func (*Bootstrapper) LabelAndUntaintNode

func (k *Bootstrapper) LabelAndUntaintNode(cfg config.ClusterConfig, n config.Node) error

func (*Bootstrapper) LogCommands

func (k *Bootstrapper) LogCommands(cfg config.ClusterConfig, o bootstrapper.LogOptions) map[string]string

LogCommands returns a map of log type to a command which will display that log.

func (*Bootstrapper) SetupCerts

func (k *Bootstrapper) SetupCerts(k8s config.ClusterConfig, n config.Node, pcpCmd cruntime.CommandRunner) error

SetupCerts sets up certificates within the cluster.

func (*Bootstrapper) StartCluster

func (k *Bootstrapper) StartCluster(cfg config.ClusterConfig) error

StartCluster starts the cluster

func (*Bootstrapper) UpdateCluster

func (k *Bootstrapper) UpdateCluster(cfg config.ClusterConfig) error

UpdateCluster updates the control plane with cluster-level info.

func (*Bootstrapper) UpdateNode

func (k *Bootstrapper) UpdateNode(cfg config.ClusterConfig, n config.Node, r cruntime.Manager) error

UpdateNode updates new or existing node.

func (*Bootstrapper) WaitForNode

func (k *Bootstrapper) WaitForNode(cfg config.ClusterConfig, n config.Node, timeout time.Duration) error

WaitForNode blocks until the node appears to be healthy

type FailFastError

type FailFastError struct {
	Err error
}

FailFastError type is an error that could not be solved by trying again

func (*FailFastError) Error

func (f *FailFastError) Error() string