kubeadm

Documentation

Index

• Constants
• func DefaultOptionsForComponentAndVersion(component string, version semver.Version) (map[string]string, error)
• func ExtraConfigForComponent(component string, opts util.ExtraOptionSlice, version semver.Version) (map[string]string, error)
• func NewKubeletConfig(k8s config.KubernetesConfig) (string, error)
• func ParseKubernetesVersion(version string) (semver.Version, error)
• func SetContainerRuntime(cfg map[string]string, runtime string) map[string]string
• func VersionIsBetween(version, gte, lte semver.Version) bool
• type ComponentExtraArgs
  • func NewComponentExtraArgs(opts util.ExtraOptionSlice, version semver.Version, featureGates string) ([]ComponentExtraArgs, error)
• type KubeadmBootstrapper
  • func NewKubeadmBootstrapper(api libmachine.API) (*KubeadmBootstrapper, error)
  • func (k *KubeadmBootstrapper) GetClusterLogsTo(follow bool, out io.Writer) error
  • func (k *KubeadmBootstrapper) GetClusterStatus() (string, error)
  • func (k *KubeadmBootstrapper) RestartCluster(k8s config.KubernetesConfig) error
  • func (k *KubeadmBootstrapper) SetupCerts(k8s config.KubernetesConfig) error
  • func (k *KubeadmBootstrapper) StartCluster(k8s config.KubernetesConfig) error
  • func (k *KubeadmBootstrapper) UpdateCluster(cfg config.KubernetesConfig) error
• type VersionedExtraOption
  • func NewUnversionedOption(component, k, v string) VersionedExtraOption

Constants

const (
	Kubelet           = "kubelet"
	Apiserver         = "apiserver"
	Scheduler         = "scheduler"
	ControllerManager = "controller-manager"
)

These are the components that can be configured through the "extra-config"

Functions

func DefaultOptionsForComponentAndVersion

func DefaultOptionsForComponentAndVersion(component string, version semver.Version) (map[string]string, error)

func ExtraConfigForComponent

func ExtraConfigForComponent(component string, opts util.ExtraOptionSlice, version semver.Version) (map[string]string, error)

ExtraConfigForComponent generates a map of flagname-value pairs for a k8s component.

func NewKubeletConfig

func NewKubeletConfig(k8s config.KubernetesConfig) (string, error)

NewKubeletConfig generates a new systemd unit containing a configured kubelet based on the options present in the KubernetesConfig.

func ParseKubernetesVersion

func ParseKubernetesVersion(version string) (semver.Version, error)

func SetContainerRuntime

func SetContainerRuntime(cfg map[string]string, runtime string) map[string]string

SetContainerRuntime possibly sets the container runtime, if it hasn't already been specified by the extra-config option. It has a set of defaults known to work for a particular runtime.

func VersionIsBetween

func VersionIsBetween(version, gte, lte semver.Version) bool

Types

type ComponentExtraArgs

type ComponentExtraArgs struct {
	Component string
	Options   map[string]string
}

func NewComponentExtraArgs

func NewComponentExtraArgs(opts util.ExtraOptionSlice, version semver.Version, featureGates string) ([]ComponentExtraArgs, error)

type KubeadmBootstrapper

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

func NewKubeadmBootstrapper

func NewKubeadmBootstrapper(api libmachine.API) (*KubeadmBootstrapper, error)

func (*KubeadmBootstrapper) GetClusterLogsTo

func (k *KubeadmBootstrapper) GetClusterLogsTo(follow bool, out io.Writer) error

TODO(r2d4): Should this aggregate all the logs from the control plane? Maybe subcommands for each component? minikube logs apiserver?

func (*KubeadmBootstrapper) GetClusterStatus

func (k *KubeadmBootstrapper) GetClusterStatus() (string, error)

TODO(r2d4): This should most likely check the health of the apiserver

func (*KubeadmBootstrapper) RestartCluster

func (k *KubeadmBootstrapper) RestartCluster(k8s config.KubernetesConfig) error

func (*KubeadmBootstrapper) SetupCerts

func (k *KubeadmBootstrapper) SetupCerts(k8s config.KubernetesConfig) error

func (*KubeadmBootstrapper) StartCluster

func (k *KubeadmBootstrapper) StartCluster(k8s config.KubernetesConfig) error

func (*KubeadmBootstrapper) UpdateCluster

func (k *KubeadmBootstrapper) UpdateCluster(cfg config.KubernetesConfig) error

type VersionedExtraOption

type VersionedExtraOption struct {

	// The flag and component that will be set
	Option util.ExtraOption

	// This flag will only be applied to versions before or equal to this version
	// If it is the default value, it will have no upper bound on versions the
	// flag is applied to
	LessThanOrEqual semver.Version

	// The flag will only be applied to versions after or equal to this version
	// If it is the default value, it will have no lower bound on versions the
	// flag is applied to
	GreaterThanOrEqual semver.Version
}

VersionedExtraOption holds information on flags to apply to a specific range of versions

func NewUnversionedOption

func NewUnversionedOption(component, k, v string) VersionedExtraOption

NewUnversionedOption returns a VersionedExtraOption that applies to all versions.