staticpod

Documentation

Index

• func ComponentPod(container v1.Container, volumes map[string]v1.Volume) v1.Pod
• func ComponentProbe(cfg *kubeadmapi.InitConfiguration, componentName string, port int, path string, ...) *v1.Probe
• func ComponentResources(cpu string) v1.ResourceRequirements
• func EtcdProbe(cfg *kubeadmapi.InitConfiguration, componentName string, port int, ...) *v1.Probe
• func GetExtraParameters(overrides map[string]string, defaults map[string]string) []string
• func GetProbeAddress(cfg *kubeadmapi.InitConfiguration, componentName string) string
• func ManifestFilesAreEqual(path1, path2 string) (bool, error)
• func NewVolume(name, path string, pathType *v1.HostPathType) v1.Volume
• func NewVolumeMount(name, path string, readOnly bool) v1.VolumeMount
• func ReadStaticPodFromDisk(manifestPath string) (*v1.Pod, error)
• func VolumeMapToSlice(volumes map[string]v1.Volume) []v1.Volume
• func VolumeMountMapToSlice(volumeMounts map[string]v1.VolumeMount) []v1.VolumeMount
• func WriteStaticPodToDisk(componentName, manifestDir string, pod v1.Pod) error

Functions

func ComponentPod

func ComponentPod(container v1.Container, volumes map[string]v1.Volume) v1.Pod

ComponentPod returns a Pod object from the container and volume specifications

func ComponentProbe

func ComponentProbe(cfg *kubeadmapi.InitConfiguration, componentName string, port int, path string, scheme v1.URIScheme) *v1.Probe

ComponentProbe is a helper function building a ready v1.Probe object from some simple parameters

func ComponentResources

func ComponentResources(cpu string) v1.ResourceRequirements

ComponentResources returns the v1.ResourceRequirements object needed for allocating a specified amount of the CPU

func EtcdProbe

func EtcdProbe(cfg *kubeadmapi.InitConfiguration, componentName string, port int, certsDir string, CACertName string, CertName string, KeyName string) *v1.Probe

EtcdProbe is a helper function for building a shell-based, etcdctl v1.Probe object to healthcheck etcd

func GetExtraParameters

func GetExtraParameters(overrides map[string]string, defaults map[string]string) []string

GetExtraParameters builds a list of flag arguments two string-string maps, one with default, base commands and one with overrides

func GetProbeAddress

func GetProbeAddress(cfg *kubeadmapi.InitConfiguration, componentName string) string

GetProbeAddress returns an IP address or 127.0.0.1 to use for liveness probes in static pod manifests.

func ManifestFilesAreEqual

func ManifestFilesAreEqual(path1, path2 string) (bool, error)

ManifestFilesAreEqual compares 2 files. It returns true if their contents are equal, false otherwise

func NewVolume

func NewVolume(name, path string, pathType *v1.HostPathType) v1.Volume

NewVolume creates a v1.Volume with a hostPath mount to the specified location

func NewVolumeMount

func NewVolumeMount(name, path string, readOnly bool) v1.VolumeMount

NewVolumeMount creates a v1.VolumeMount to the specified location

func ReadStaticPodFromDisk

func ReadStaticPodFromDisk(manifestPath string) (*v1.Pod, error)

ReadStaticPodFromDisk reads a static pod file from disk

func VolumeMapToSlice

func VolumeMapToSlice(volumes map[string]v1.Volume) []v1.Volume

VolumeMapToSlice returns a slice of volumes from a map's values

func VolumeMountMapToSlice

func VolumeMountMapToSlice(volumeMounts map[string]v1.VolumeMount) []v1.VolumeMount

VolumeMountMapToSlice returns a slice of volumes from a map's values

func WriteStaticPodToDisk

func WriteStaticPodToDisk(componentName, manifestDir string, pod v1.Pod) error

WriteStaticPodToDisk writes a static pod file to disk