spark

Dec 15, 2022

Changes in this version

+ var Meta = metadata.NewProvider(ApplicationName, func(obj client.Object) string { ... }, ...)

Aug 12, 2021

Changes in this version

+ func NewEnvoyFilter(sc *dcv1alpha1.SparkCluster) *apinetworkingv1alpha3.EnvoyFilter

Jul 2, 2021

Changes in this version

+ func AddGlobalLabels(labels map[string]string, globalLabels map[string]string) map[string]string

Jun 30, 2021

Changes in this version

+ func DriverServiceName(name string) string

+ func FrameworkConfigMapName(instance string, comp Component) string

+ func KeyTabConfigMapName(instance string, comp Component) string

+ func MasterServiceName(name string) string

+ func NewClusterDriverNetworkPolicy(sc *dcv1alpha1.SparkCluster) *networkingv1.NetworkPolicy

+ func NewClusterMasterNetworkPolicy(sc *dcv1alpha1.SparkCluster) *networkingv1.NetworkPolicy

+ func NewClusterWorkerNetworkPolicy(sc *dcv1alpha1.SparkCluster) *networkingv1.NetworkPolicy

+ func NewFrameworkConfigMap(sc *dcv1alpha1.SparkCluster) *corev1.ConfigMap

+ func NewKeyTabConfigMap(sc *dcv1alpha1.SparkCluster) *corev1.ConfigMap

+ func NewSparkDriverService(sc *dcv1alpha1.SparkCluster) *corev1.Service

May 12, 2021

Changes in this version

+ func HeadServiceName(name string) string

+ func HeadlessServiceName(name string) string

+ func HorizontalPodAutoscalerObjectMeta(sc *dcv1alpha1.SparkCluster) metav1.ObjectMeta

+ func InstanceObjectName(instance string, comp Component) string

+ func MetadataLabels(sc *dcv1alpha1.SparkCluster) map[string]string

+ func MetadataLabelsWithComponent(sc *dcv1alpha1.SparkCluster, comp Component) map[string]string

+ func NewClusterNetworkPolicy(sc *dcv1alpha1.SparkCluster) *networkingv1.NetworkPolicy

+ func NewHeadClientNetworkPolicy(sc *dcv1alpha1.SparkCluster) *networkingv1.NetworkPolicy

+ func NewHeadDashboardNetworkPolicy(sc *dcv1alpha1.SparkCluster) *networkingv1.NetworkPolicy

+ func NewHeadlessService(sc *dcv1alpha1.SparkCluster) *corev1.Service

+ func NewHorizontalPodAutoscaler(sc *dcv1alpha1.SparkCluster) (*autoscalingv2beta2.HorizontalPodAutoscaler, error)

+ func NewMasterService(sc *dcv1alpha1.SparkCluster) *corev1.Service

+ func NewPodSecurityPolicyRBAC(sc *dcv1alpha1.SparkCluster) (*rbacv1.Role, *rbacv1.RoleBinding)

+ func NewServiceAccount(sc *dcv1alpha1.SparkCluster) *corev1.ServiceAccount

+ func NewStatefulSet(sc *dcv1alpha1.SparkCluster, comp Component) (*appsv1.StatefulSet, error)

+ func SelectorLabels(sc *dcv1alpha1.SparkCluster) map[string]string

+ func SelectorLabelsWithComponent(sc *dcv1alpha1.SparkCluster, comp Component) map[string]string

+ type Component string

+ const ApplicationName

+ const ComponentMaster

+ const ComponentNone

+ const ComponentWorker