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
Constants ¶
This section is empty.
Variables ¶
This section is empty.
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.
Types ¶
This section is empty.
Source Files
Click to show internal directories.
Click to hide internal directories.