worker

Documentation

Overview

Copyright 2021 k0s authors

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Copyright 2021 k0s authors

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Copyright 2021 k0s authors

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Index

• func HandleKubeletBootstrapToken(encodedToken string, k0sVars constant.CfgVars) error
• func KernelSetup()
• type CalicoInstaller
  • func (c CalicoInstaller) Healthy() error
  • func (c CalicoInstaller) Init() error
  • func (c CalicoInstaller) Run() error
  • func (c CalicoInstaller) Stop() error
• type ContainerD
  • func (c *ContainerD) Healthy() error
  • func (c *ContainerD) Init() error
  • func (c *ContainerD) Run() error
  • func (c *ContainerD) Stop() error
• type KubeProxy
  • func (k KubeProxy) Healthy() error
  • func (k KubeProxy) Init() error
  • func (k KubeProxy) Run() error
  • func (k KubeProxy) Stop() error
• type Kubelet
  • func (k *Kubelet) Healthy() error
  • func (k *Kubelet) Init() error
  • func (k *Kubelet) Run() error
  • func (k *Kubelet) Stop() error
• type KubeletConfigClient
  • func LoadKubeletConfigClient(k0svars constant.CfgVars) (*KubeletConfigClient, error)
  • func NewKubeletConfigClient(kubeconfigPath string) (*KubeletConfigClient, error)
  • func (k *KubeletConfigClient) Get(profile string) (string, error)
• type OCIBundleReconciler
  • func NewOCIBundleReconciler(vars constant.CfgVars) *OCIBundleReconciler
  • func (a *OCIBundleReconciler) Healthy() error
  • func (a *OCIBundleReconciler) Init() error
  • func (a *OCIBundleReconciler) Run() error
  • func (a *OCIBundleReconciler) Stop() error

Functions

func HandleKubeletBootstrapToken

func HandleKubeletBootstrapToken(encodedToken string, k0sVars constant.CfgVars) error

func KernelSetup

func KernelSetup()

KernelSetup sets the needed kernel tuning params. If setting the options fails, it only logs a warning but does not prevent the starting of worker

Types

type CalicoInstaller

type CalicoInstaller struct {
	Token      string
	APIAddress string
	CIDRRange  string
	ClusterDNS string
}

func (CalicoInstaller) Healthy

func (c CalicoInstaller) Healthy() error

func (CalicoInstaller) Init

func (c CalicoInstaller) Init() error

func (CalicoInstaller) Run

func (c CalicoInstaller) Run() error

func (CalicoInstaller) Stop

func (c CalicoInstaller) Stop() error

type ContainerD

type ContainerD struct {
	LogLevel string
	K0sVars  constant.CfgVars

	OCIBundlePath string
	// contains filtered or unexported fields
}

ContainerD implement the component interface to manage containerd as k0s component

func (*ContainerD) Healthy

func (c *ContainerD) Healthy() error

Health-check interface

func (*ContainerD) Init

func (c *ContainerD) Init() error

Init extracts the needed binaries

func (*ContainerD) Run

func (c *ContainerD) Run() error

Run runs containerD

func (*ContainerD) Stop

func (c *ContainerD) Stop() error

Stop stops containerD

type KubeProxy

type KubeProxy struct {
	K0sVars   constant.CfgVars
	CIDRRange string
	LogLevel  string
}

func (KubeProxy) Healthy

func (k KubeProxy) Healthy() error

func (KubeProxy) Init

func (k KubeProxy) Init() error

func (KubeProxy) Run

func (k KubeProxy) Run() error

func (KubeProxy) Stop

func (k KubeProxy) Stop() error

type Kubelet

type Kubelet struct {
	CRISocket           string
	EnableCloudProvider bool
	K0sVars             constant.CfgVars
	KubeletConfigClient *KubeletConfigClient
	LogLevel            string
	Profile             string

	ClusterDNS string
	Labels     []string
	ExtraArgs  string
	// contains filtered or unexported fields
}

Kubelet is the component implementation to manage kubelet

func (*Kubelet) Healthy

func (k *Kubelet) Healthy() error

Health-check interface

func (*Kubelet) Init

func (k *Kubelet) Init() error

Init extracts the needed binaries

func (*Kubelet) Run

func (k *Kubelet) Run() error

Run runs kubelet

func (*Kubelet) Stop

func (k *Kubelet) Stop() error

Stop stops kubelet

type KubeletConfigClient

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

KubeletConfigClient is the client used to fetch kubelet config from a common config map

func LoadKubeletConfigClient

func LoadKubeletConfigClient(k0svars constant.CfgVars) (*KubeletConfigClient, error)

func NewKubeletConfigClient

func NewKubeletConfigClient(kubeconfigPath string) (*KubeletConfigClient, error)

NewKubeletConfigClient creates new KubeletConfigClient using the specified kubeconfig

func (*KubeletConfigClient) Get

func (k *KubeletConfigClient) Get(profile string) (string, error)

Get reads the config from kube api

type OCIBundleReconciler

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

OCIBundleReconciler tries to import OCI bundle into the running containerd instance

func NewOCIBundleReconciler

func NewOCIBundleReconciler(vars constant.CfgVars) *OCIBundleReconciler

NewOCIBundleReconciler builds new reconciler

func (*OCIBundleReconciler) Healthy

func (a *OCIBundleReconciler) Healthy() error

func (*OCIBundleReconciler) Init

func (a *OCIBundleReconciler) Init() error

func (*OCIBundleReconciler) Run

func (a *OCIBundleReconciler) Run() error

func (*OCIBundleReconciler) Stop

func (a *OCIBundleReconciler) Stop() error