util

Documentation

Index

• func AddOwnerReference(meta *metav1.ObjectMeta, rss *v1alpha1.RemoteShuffleService)
• func CreateRecorder(kubeClient kubernetes.Interface, component string) record.EventRecorder
• func GenerateHostPathVolume(hostPath, subPath string) *corev1.Volume
• func GenerateHostPathVolumeMounts(hostPathMounts map[string]string) []corev1.VolumeMount
• func GenerateHostPathVolumeName(hostPath string) string
• func GenerateHostPathVolumes(hostPathMounts map[string]string, logHostPath, subPath string) []corev1.Volume
• func GenerateInitContainers(rssPodSpec *v1alpha1.RSSPodSpec) []corev1.Container
• func GenerateMainContainer(name, configDir string, podSpec *v1alpha1.RSSPodSpec, ...) *corev1.Container
• func GetConfigMapOwner(cm *corev1.ConfigMap) string

Functions

func AddOwnerReference

func AddOwnerReference(meta *metav1.ObjectMeta, rss *v1alpha1.RemoteShuffleService)

AddOwnerReference add OwnerReference to an object.

func CreateRecorder

func CreateRecorder(kubeClient kubernetes.Interface, component string) record.EventRecorder

CreateRecorder creates an event recorder.

func GenerateHostPathVolume

func GenerateHostPathVolume(hostPath, subPath string) *corev1.Volume

GenerateHostPathVolume convert host path to hostPath volume.

func GenerateHostPathVolumeMounts

func GenerateHostPathVolumeMounts(hostPathMounts map[string]string) []corev1.VolumeMount

GenerateHostPathVolumeMounts generates volume mounts for hostPaths configured in rss objects.

func GenerateHostPathVolumeName

func GenerateHostPathVolumeName(hostPath string) string

GenerateHostPathVolumeName converts host path to volume name.

func GenerateHostPathVolumes

func GenerateHostPathVolumes(hostPathMounts map[string]string, logHostPath, subPath string) []corev1.Volume

GenerateHostPathVolumes generates all hostPath volumes. If logHostPath is not empty, we need to handle it in a special way by adding the subPath to the hostPath which is the same as logHostPath.

func GenerateInitContainers

func GenerateInitContainers(rssPodSpec *v1alpha1.RSSPodSpec) []corev1.Container

GenerateInitContainers generates init containers for coordinators and shuffle servers.

func GenerateMainContainer

func GenerateMainContainer(name, configDir string, podSpec *v1alpha1.RSSPodSpec,
	ports []corev1.ContainerPort, env []corev1.EnvVar,
	initVolumeMounts []corev1.VolumeMount) *corev1.Container

GenerateMainContainer generate main container of coordinators or shuffle servers.

func GetConfigMapOwner

func GetConfigMapOwner(cm *corev1.ConfigMap) string

GetConfigMapOwner returns name of rss object as owner of configMap.