preflight

Documentation

Index

• func RunChecks(checks []Checker, ww io.Writer) error
• func RunInitMasterChecks(cfg *kubeadmapi.MasterConfiguration) error
• func RunJoinNodeChecks(cfg *kubeadmapi.NodeConfiguration) error
• func RunRootCheckOnly() error
• func TryStartKubelet()
• type Checker
• type DirAvailableCheck
  • func (dac DirAvailableCheck) Check() (warnings, errors []error)
• type Error
  • func (e *Error) Error() string
• type ExternalEtcdVersionCheck
  • func (evc ExternalEtcdVersionCheck) Check() (warnings, errors []error)
• type ExtraArgsCheck
  • func (eac ExtraArgsCheck) Check() (warnings, errors []error)
• type FileAvailableCheck
  • func (fac FileAvailableCheck) Check() (warnings, errors []error)
• type FileContentCheck
  • func (fcc FileContentCheck) Check() (warnings, errors []error)
• type FileExistingCheck
  • func (fac FileExistingCheck) Check() (warnings, errors []error)
• type FirewalldCheck
  • func (fc FirewalldCheck) Check() (warnings, errors []error)
• type HTTPProxyCheck
  • func (hst HTTPProxyCheck) Check() (warnings, errors []error)
• type HostnameCheck
  • func (hc HostnameCheck) Check() (warnings, errors []error)
• type InPathCheck
  • func (ipc InPathCheck) Check() (warnings, errors []error)
• type IsRootCheck
  • func (irc IsRootCheck) Check() (warnings, errors []error)
• type PortOpenCheck
  • func (poc PortOpenCheck) Check() (warnings, errors []error)
• type ServiceCheck
  • func (sc ServiceCheck) Check() (warnings, errors []error)
• type SystemVerificationCheck
  • func (sysver SystemVerificationCheck) Check() (warnings, errors []error)

Functions

func RunChecks

func RunChecks(checks []Checker, ww io.Writer) error

RunChecks runs each check, displays it's warnings/errors, and once all are processed will exit if any errors occurred.

func RunInitMasterChecks

func RunInitMasterChecks(cfg *kubeadmapi.MasterConfiguration) error

func RunJoinNodeChecks

func RunJoinNodeChecks(cfg *kubeadmapi.NodeConfiguration) error

func RunRootCheckOnly

func RunRootCheckOnly() error

func TryStartKubelet

func TryStartKubelet()

Types

type Checker

type Checker interface {
	Check() (warnings, errors []error)
}

Checker validates the state of the system to ensure kubeadm will be successful as often as possilble.

type DirAvailableCheck

type DirAvailableCheck struct {
	Path string
}

DirAvailableCheck checks if the given directory either does not exist, or is empty.

func (DirAvailableCheck) Check

func (dac DirAvailableCheck) Check() (warnings, errors []error)

type Error

type Error struct {
	Msg string
}

func (*Error) Error

func (e *Error) Error() string

type ExternalEtcdVersionCheck

type ExternalEtcdVersionCheck struct {
	Etcd kubeadmapi.Etcd
}

ExternalEtcdVersionCheck checks if version of external etcd meets the demand of kubeadm

func (ExternalEtcdVersionCheck) Check

func (evc ExternalEtcdVersionCheck) Check() (warnings, errors []error)

type ExtraArgsCheck

type ExtraArgsCheck struct {
	APIServerExtraArgs         map[string]string
	ControllerManagerExtraArgs map[string]string
	SchedulerExtraArgs         map[string]string
}

ExtraArgsCheck checks if arguments are valid.

func (ExtraArgsCheck) Check

func (eac ExtraArgsCheck) Check() (warnings, errors []error)

type FileAvailableCheck

type FileAvailableCheck struct {
	Path string
}

FileAvailableCheck checks that the given file does not already exist.

func (FileAvailableCheck) Check

func (fac FileAvailableCheck) Check() (warnings, errors []error)

type FileContentCheck

type FileContentCheck struct {
	Path    string
	Content []byte
}

FileContentCheck checks that the given file contains the string Content.

func (FileContentCheck) Check

func (fcc FileContentCheck) Check() (warnings, errors []error)

type FileExistingCheck

type FileExistingCheck struct {
	Path string
}

FileExistingCheck checks that the given file does not already exist.

func (FileExistingCheck) Check

func (fac FileExistingCheck) Check() (warnings, errors []error)

type FirewalldCheck

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

FirewalldCheck checks if firewalld is enabled or active, and if so outputs a warning.

func (FirewalldCheck) Check

func (fc FirewalldCheck) Check() (warnings, errors []error)

type HTTPProxyCheck

type HTTPProxyCheck struct {
	Proto string
	Host  string
	Port  int
}

HTTPProxyCheck checks if https connection to specific host is going to be done directly or over proxy. If proxy detected, it will return warning.

func (HTTPProxyCheck) Check

func (hst HTTPProxyCheck) Check() (warnings, errors []error)

type HostnameCheck

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

HostnameCheck checks if hostname match dns sub domain regex. If hostname doesn't match this regex, kubelet will not launch static pods like kube-apiserver/kube-controller-manager and so on.

func (HostnameCheck) Check

func (hc HostnameCheck) Check() (warnings, errors []error)

type InPathCheck

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

InPathCheck checks if the given executable is present in the path

func (InPathCheck) Check

func (ipc InPathCheck) Check() (warnings, errors []error)

type IsRootCheck

type IsRootCheck struct{}

IsRootCheck verifies user is root

func (IsRootCheck) Check

func (irc IsRootCheck) Check() (warnings, errors []error)

type PortOpenCheck

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

PortOpenCheck ensures the given port is available for use.

func (PortOpenCheck) Check

func (poc PortOpenCheck) Check() (warnings, errors []error)

type ServiceCheck

type ServiceCheck struct {
	Service       string
	CheckIfActive bool
}

ServiceCheck verifies that the given service is enabled and active. If we do not detect a supported init system however, all checks are skipped and a warning is returned.

func (ServiceCheck) Check

func (sc ServiceCheck) Check() (warnings, errors []error)

type SystemVerificationCheck

type SystemVerificationCheck struct{}

func (SystemVerificationCheck) Check

func (sysver SystemVerificationCheck) Check() (warnings, errors []error)