worker

package
v0.13.1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 15, 2021 License: Apache-2.0 Imports: 25 Imported by: 0

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.

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.

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

Constants

This section is empty.

Variables

This section is empty.

Functions

func HandleKubeletBootstrapToken added in v0.13.0

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 added in v0.9.0

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

func (CalicoInstaller) Healthy added in v0.9.0

func (c CalicoInstaller) Healthy() error

func (CalicoInstaller) Init added in v0.9.0

func (c CalicoInstaller) Init() error

func (CalicoInstaller) Run added in v0.9.0

func (c CalicoInstaller) Run() error

func (CalicoInstaller) Stop added in v0.9.0

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 added in v0.9.0

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

func (KubeProxy) Healthy added in v0.9.0

func (k KubeProxy) Healthy() error

func (KubeProxy) Init added in v0.9.0

func (k KubeProxy) Init() error

func (KubeProxy) Run added in v0.9.0

func (k KubeProxy) Run() error

func (KubeProxy) Stop added in v0.9.0

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 added in v0.13.0

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 added in v0.12.0

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

OCIBundleReconciler tries to import OCI bundle into the running containerd instance

func NewOCIBundleReconciler added in v0.12.0

func NewOCIBundleReconciler(vars constant.CfgVars) *OCIBundleReconciler

NewOCIBundleReconciler builds new reconciler

func (*OCIBundleReconciler) Healthy added in v0.12.0

func (a *OCIBundleReconciler) Healthy() error

func (*OCIBundleReconciler) Init added in v0.12.0

func (a *OCIBundleReconciler) Init() error

func (*OCIBundleReconciler) Run added in v0.12.0

func (a *OCIBundleReconciler) Run() error

func (*OCIBundleReconciler) Stop added in v0.12.0

func (a *OCIBundleReconciler) Stop() error

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL