kubelet

package

v0.3.0 Latest Latest Go to latest Published: May 24, 2020 License: Apache-2.0 Imports: 16 Imported by: 1

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/flexkube/libflexkube

Links

Open Source Insights

Documentation ¶

Overview ¶

Package kubelet implements logic needed for creating and managing kubelet instances running as containers.

Index ¶

Constants
func FromYaml(c []byte) (types.Resource, error)
type Kubelet
- func (k *Kubelet) New() (container.ResourceInstance, error)
- func (k *Kubelet) Validate() error
type Pool
- func (p *Pool) New() (types.Resource, error)
- func (p *Pool) Validate() error

Constants ¶

View Source

const (
	// DefaultNetworkPlugin is a default NetworkPlugin configured for kubelets.
	DefaultNetworkPlugin = "cni"
	// DefaultHairpinMode is a default HairpinMode configured for kubelets.
	DefaultHairpinMode = "hairpin-veth"
)

View Source

const (
	// KubenetNetworkPlugin is the name of kubenet network plugin.
	KubenetNetworkPlugin = "kubenet"
)

Variables ¶

This section is empty.

Functions ¶

func FromYaml ¶

func FromYaml(c []byte) (types.Resource, error)

FromYaml allows to restore cluster state from YAML.

Types ¶

type Kubelet ¶

type Kubelet struct {
	Address                 string                 `json:"address,omitempty"`
	Image                   string                 `json:"image,omitempty"`
	Host                    host.Host              `json:"host,omitempty"`
	BootstrapConfig         *client.Config         `json:"bootstrapConfig,omitempty"`
	KubernetesCACertificate types.Certificate      `json:"kubernetesCACertificate,omitempty"`
	ClusterDNSIPs           []string               `json:"clusterDNSIPs,omitempty"`
	Name                    string                 `json:"name,omitempty"`
	Taints                  map[string]string      `json:"taints,omitempty"`
	Labels                  map[string]string      `json:"labels,omitempty"`
	PrivilegedLabels        map[string]string      `json:"privilegedLabels,omitempty"`
	AdminConfig             *client.Config         `json:"adminConfig,omitempty"`
	CgroupDriver            string                 `json:"cgroupDriver,omitempty"`
	NetworkPlugin           string                 `json:"networkPlugin,omitempty"`
	SystemReserved          map[string]string      `json:"systemReserved,omitempty"`
	KubeReserved            map[string]string      `json:"kubeReserved,omitempty"`
	HairpinMode             string                 `json:"hairpinMode,omitempty"`
	VolumePluginDir         string                 `json:"volumePluginDir,omitempty"`
	ExtraMounts             []containertypes.Mount `json:"extraMounts,omitempty"`

	// Depending on the network plugin, this should be optional, but for now it's required.
	PodCIDR string `json:"podCIDR,omitempty"`
}

Kubelet represents single kubelet instance.

func (*Kubelet) New ¶

func (k *Kubelet) New() (container.ResourceInstance, error)

New validates Kubelet configuration and returns it's usable version.

func (*Kubelet) Validate ¶

func (k *Kubelet) Validate() error

Validate validates kubelet configuration.

TODO: Better validation should be done here.

type Pool ¶

type Pool struct {
	// User-configurable fields.
	Image                   string                 `json:"image,omitempty"`
	SSH                     *ssh.Config            `json:"ssh,omitempty"`
	BootstrapConfig         *client.Config         `json:"bootstrapConfig,omitempty"`
	Kubelets                []Kubelet              `json:"kubelets,omitempty"`
	KubernetesCACertificate types.Certificate      `json:"kubernetesCACertificate,omitempty"`
	ClusterDNSIPs           []string               `json:"clusterDNSIPs,omitempty"`
	Taints                  map[string]string      `json:"taints,omitempty"`
	Labels                  map[string]string      `json:"labels,omitempty"`
	PrivilegedLabels        map[string]string      `json:"privilegedLabels,omitempty"`
	AdminConfig             *client.Config         `json:"adminConfig,omitempty"`
	CgroupDriver            string                 `json:"cgroupDriver,omitempty"`
	NetworkPlugin           string                 `json:"networkPlugin,omitempty"`
	SystemReserved          map[string]string      `json:"systemReserved,omitempty"`
	KubeReserved            map[string]string      `json:"kubeReserved,omitempty"`
	HairpinMode             string                 `json:"hairpinMode,omitempty"`
	VolumePluginDir         string                 `json:"volumePluginDir,omitempty"`
	ExtraMounts             []containertypes.Mount `json:"extraMounts,omitempty"`
	PKI                     *pki.PKI               `json:"pki,omitempty"`

	// Serializable fields.
	State container.ContainersState `json:"state,omitempty"`
}

Pool represents group of kubelet instances and their configuration.

func (*Pool) New ¶

func (p *Pool) New() (types.Resource, error)

New validates kubelet pool configuration and fills all members with configured values.

func (*Pool) Validate ¶

func (p *Pool) Validate() error

Validate validates Pool configuration.

TODO: Add actual validation.

Source Files ¶

View all Source files

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