coordinator

Documentation

Index

• func GenerateAddresses(rss *unifflev1alpha1.RemoteShuffleService) string
• func GenerateCM(rss *unifflev1alpha1.RemoteShuffleService) *corev1.ConfigMap
• func GenerateCoordinators(rss *unifflev1alpha1.RemoteShuffleService) (*corev1.ServiceAccount, *corev1.ConfigMap, []*corev1.Service, ...)
• func GenerateDeploy(rss *unifflev1alpha1.RemoteShuffleService, index int) *appsv1.Deployment
• func GenerateHeadlessSvc(rss *unifflev1alpha1.RemoteShuffleService, index int) *corev1.Service
• func GenerateNameByIndex(rss *unifflev1alpha1.RemoteShuffleService, index int) string
• func GenerateProperties(rss *unifflev1alpha1.RemoteShuffleService) map[controllerconstants.PropertyKey]string
• func GenerateSA(rss *unifflev1alpha1.RemoteShuffleService) *corev1.ServiceAccount
• func GenerateSvc(rss *unifflev1alpha1.RemoteShuffleService, index int) *corev1.Service

Functions

func GenerateAddresses

func GenerateAddresses(rss *unifflev1alpha1.RemoteShuffleService) string

GenerateAddresses returns addresses of coordinators accessed by shuffle servers.

func GenerateCM

func GenerateCM(rss *unifflev1alpha1.RemoteShuffleService) *corev1.ConfigMap

GenerateCM generates configMap used by coordinators.

func GenerateCoordinators

func GenerateCoordinators(rss *unifflev1alpha1.RemoteShuffleService) (
	*corev1.ServiceAccount, *corev1.ConfigMap, []*corev1.Service, []*appsv1.Deployment)

GenerateCoordinators generates objects related to coordinators

func GenerateDeploy

func GenerateDeploy(rss *unifflev1alpha1.RemoteShuffleService, index int) *appsv1.Deployment

GenerateDeploy generates deployment of specific coordinator.

func GenerateHeadlessSvc

func GenerateHeadlessSvc(rss *unifflev1alpha1.RemoteShuffleService, index int) *corev1.Service

GenerateHeadlessSvc generates a headless service for corresponding coordinator.

func GenerateNameByIndex

func GenerateNameByIndex(rss *unifflev1alpha1.RemoteShuffleService, index int) string

GenerateNameByIndex returns workload or service name of coordinator by index.

func GenerateProperties

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

GenerateProperties generates configuration properties of coordinators.

func GenerateSA

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

GenerateSA generates service account of coordinator.

func GenerateSvc

func GenerateSvc(rss *unifflev1alpha1.RemoteShuffleService, index int) *corev1.Service

GenerateSvc generates NodePort service used by specific coordinator. If no RPCNodePort/HTTPNodePort is specified,

this function is skipped.