shuffleserver

Documentation

Index

• func GenerateHPA(rss *unifflev1alpha1.RemoteShuffleService) (*autoscalingv2.HorizontalPodAutoscaler, bool)
• func GenerateName(rss *unifflev1alpha1.RemoteShuffleService) string
• func GenerateProperties(rss *unifflev1alpha1.RemoteShuffleService) map[controllerconstants.PropertyKey]string
• func GenerateSA(rss *unifflev1alpha1.RemoteShuffleService) *corev1.ServiceAccount
• func GenerateShuffleServers(kubeClient kubernetes.Interface, rss *unifflev1alpha1.RemoteShuffleService) (*corev1.ServiceAccount, *appsv1.StatefulSet)
• func GenerateSts(kubeClient kubernetes.Interface, rss *unifflev1alpha1.RemoteShuffleService) *appsv1.StatefulSet

Functions

func GenerateHPA

func GenerateHPA(rss *unifflev1alpha1.RemoteShuffleService) (*autoscalingv2.HorizontalPodAutoscaler, bool)

GenerateHPA generates hpa object of shuffle servers and return when it is enabled.

func GenerateName

func GenerateName(rss *unifflev1alpha1.RemoteShuffleService) string

GenerateName returns workload or nodePort service name of shuffle server.

func GenerateProperties

func GenerateProperties(rss *unifflev1alpha1.RemoteShuffleService) map[controllerconstants.PropertyKey]string

GenerateProperties generates configuration properties of shuffle servers.

func GenerateSA

func GenerateSA(rss *unifflev1alpha1.RemoteShuffleService) *corev1.ServiceAccount

GenerateSA generates service account of shuffle servers.

func GenerateShuffleServers

func GenerateShuffleServers(kubeClient kubernetes.Interface, rss *unifflev1alpha1.RemoteShuffleService) (
	*corev1.ServiceAccount, *appsv1.StatefulSet)

GenerateShuffleServers generates objects related to shuffle servers.

func GenerateSts

func GenerateSts(kubeClient kubernetes.Interface, rss *unifflev1alpha1.RemoteShuffleService) *appsv1.StatefulSet

GenerateSts generates statefulSet of shuffle servers.