pod

Documentation

Index

• Constants
• func Annotations(spec v1.SpecInterface) map[string]string
• func ContainerArgs(spec v1.SpecInterface) []string
• func ContainerCommand(spec v1.SpecInterface) []string
• func ContainerSecurityContext(spec v1.SpecInterface) *corev1.SecurityContext
• func Count(podList v1.PodList) (creating, ready, failed []string)
• func Envs(spec v1.SpecInterface, config map[string]interface{}, ...) []corev1.EnvVar
• func Labels(clusterName string, spec v1.SpecInterface) map[string]string
• func LifeCycle(lifeCycle *corev1.Lifecycle, preStopScriptPath string) *corev1.Lifecycle
• func LivenessProbe(livenessProbeFailureSeconds *int32, port int32, path string) *corev1.Probe
• func MountConfigMapInfo(volumes []corev1.Volume, volumeMounts []corev1.VolumeMount, ...) ([]corev1.Volume, []corev1.VolumeMount)
• func MountConfigMaps(spec v1.SpecInterface, volumes []corev1.Volume, ...) ([]corev1.Volume, []corev1.VolumeMount)
• func MountEmptyDirVolume(volumes []corev1.Volume, volumeMounts []corev1.VolumeMount, ...) ([]corev1.Volume, []corev1.VolumeMount)
• func MountHostPathVolume(volumes []corev1.Volume, volumeMounts []corev1.VolumeMount, volumeName string, ...) ([]corev1.Volume, []corev1.VolumeMount)
• func MountPersistentVolumeClaim(volumes []corev1.Volume, volumeMounts []corev1.VolumeMount, ...) ([]corev1.Volume, []corev1.VolumeMount)
• func MountSecrets(volumes []corev1.Volume, volumeMounts []corev1.VolumeMount, ...) ([]corev1.Volume, []corev1.VolumeMount)
• func MountStorageVolumes(spec v1.SpecInterface) ([]corev1.Volume, []corev1.VolumeMount)
• func PodSecurityContext(spec v1.SpecInterface) *corev1.PodSecurityContext
• func Ports(spec v1.SpecInterface, config map[string]interface{}) []corev1.ContainerPort
• func ReadinessProbe(readinessProbeFailureSeconds *int32, port int32, path string) *corev1.Probe
• func Spec(spec v1.SpecInterface, container corev1.Container, volumes []corev1.Volume) corev1.PodSpec
• func SpecialStorageClassName(sv v1.StorageVolume) string
• func StartupProbe(startupProbeFailureSeconds *int32, port int32, path string) *corev1.Probe
• func Status(podList v1.PodList) map[string]PodStatus
• type PodStatus

Constants

const (
	HEALTH_API_PATH = "/api/health"
)

Functions

func Annotations

func Annotations(spec v1.SpecInterface) map[string]string

func ContainerArgs

func ContainerArgs(spec v1.SpecInterface) []string

func ContainerCommand

func ContainerCommand(spec v1.SpecInterface) []string

func ContainerSecurityContext

func ContainerSecurityContext(spec v1.SpecInterface) *corev1.SecurityContext

func Count

func Count(podList v1.PodList) (creating, ready, failed []string)

func Envs

func Envs(spec v1.SpecInterface, config map[string]interface{},
	feExternalServiceName string, namespace string, envs []corev1.EnvVar) []corev1.EnvVar

func Labels

func Labels(clusterName string, spec v1.SpecInterface) map[string]string

func LifeCycle

func LifeCycle(lifeCycle *corev1.Lifecycle, preStopScriptPath string) *corev1.Lifecycle

LifeCycle returns a lifecycle.

func LivenessProbe

func LivenessProbe(livenessProbeFailureSeconds *int32, port int32, path string) *corev1.Probe

LivenessProbe returns a liveness probe.

func MountConfigMapInfo

func MountConfigMapInfo(volumes []corev1.Volume, volumeMounts []corev1.VolumeMount,
	cmInfo v1.ConfigMapInfo, mountPath string) ([]corev1.Volume, []corev1.VolumeMount)

MountConfigMapInfo parse ConfigMapInfo from spec and mount them to pod. Note: we can not reuse MountConfigMaps because it generates a volume name by call getVolumeName,

func MountConfigMaps

func MountConfigMaps(spec v1.SpecInterface, volumes []corev1.Volume, volumeMounts []corev1.VolumeMount,
	references []v1.ConfigMapReference) ([]corev1.Volume, []corev1.VolumeMount)

func MountEmptyDirVolume

func MountEmptyDirVolume(volumes []corev1.Volume, volumeMounts []corev1.VolumeMount,
	volumeName, mountPath, subPath string) ([]corev1.Volume, []corev1.VolumeMount)

func MountHostPathVolume

func MountHostPathVolume(volumes []corev1.Volume, volumeMounts []corev1.VolumeMount,
	volumeName string, mountPath string, subPath string,
	hostPath *corev1.HostPathVolumeSource) ([]corev1.Volume, []corev1.VolumeMount)

func MountPersistentVolumeClaim

func MountPersistentVolumeClaim(volumes []corev1.Volume, volumeMounts []corev1.VolumeMount,
	volumeName, mountPath, subPath string) ([]corev1.Volume, []corev1.VolumeMount)

func MountSecrets

func MountSecrets(volumes []corev1.Volume, volumeMounts []corev1.VolumeMount,
	references []v1.SecretReference) ([]corev1.Volume, []corev1.VolumeMount)

func MountStorageVolumes

func MountStorageVolumes(spec v1.SpecInterface) ([]corev1.Volume, []corev1.VolumeMount)

MountStorageVolumes parse StorageVolumes from spec and mount them to pod. If StorageClassName is EmptyDir, mount an emptyDir volume to pod.

func PodSecurityContext

func PodSecurityContext(spec v1.SpecInterface) *corev1.PodSecurityContext

func Ports

func Ports(spec v1.SpecInterface, config map[string]interface{}) []corev1.ContainerPort

func ReadinessProbe

func ReadinessProbe(readinessProbeFailureSeconds *int32, port int32, path string) *corev1.Probe

ReadinessProbe returns a readiness probe.

func Spec

func Spec(spec v1.SpecInterface, container corev1.Container, volumes []corev1.Volume) corev1.PodSpec

func SpecialStorageClassName

func SpecialStorageClassName(sv v1.StorageVolume) string

SpecialStorageClassName returns the special storage class name of the storage volume, else return "". Now we support HostPath and EmptyDir as special storage class.

func StartupProbe

func StartupProbe(startupProbeFailureSeconds *int32, port int32, path string) *corev1.Probe

StartupProbe returns a startup probe.

func Status

func Status(podList v1.PodList) map[string]PodStatus

Status return the status of pods.

Types

type PodStatus

type PodStatus struct {
	Phase  v1.PodPhase
	Reason string
}