sparkconnect

Documentation

Index

• Constants
• func GetCommonLabels(conn *v1alpha1.SparkConnect) map[string]string
• func GetConfigMapName(conn *v1alpha1.SparkConnect) string
• func GetExecutorSelectorLabels(conn *v1alpha1.SparkConnect) map[string]string
• func GetServerPodName(conn *v1alpha1.SparkConnect) string
• func GetServerSelectorLabels(conn *v1alpha1.SparkConnect) map[string]string
• func GetServerServiceHost(conn *v1alpha1.SparkConnect) string
• func GetServerServiceName(conn *v1alpha1.SparkConnect) string
• type Options
• type Reconciler
  • func NewReconciler(manager ctrl.Manager, scheme *runtime.Scheme, client client.Client, ...) *Reconciler
  • func (r *Reconciler) Reconcile(ctx context.Context, req ctrl.Request) (reconcile.Result, error)
  • func (r *Reconciler) SetupWithManager(mgr ctrl.Manager, options controller.Options) error

Constants

const (
	ExecutorPodTemplateFileName = "executor-pod-template.yaml"
)

Functions

func GetCommonLabels

func GetCommonLabels(conn *v1alpha1.SparkConnect) map[string]string

GetCommonLabels returns the labels for resources owned by SparkConnect.

func GetConfigMapName

func GetConfigMapName(conn *v1alpha1.SparkConnect) string

GetConfigMapName returns the name of the config map for SparkConnect.

func GetExecutorSelectorLabels

func GetExecutorSelectorLabels(conn *v1alpha1.SparkConnect) map[string]string

GetExecutorSelectorLabels returns the labels used to select executor pods owned by Spark connect server pod.

func GetServerPodName

func GetServerPodName(conn *v1alpha1.SparkConnect) string

GetServerPodName returns the name of the server pod for SparkConnect.

func GetServerSelectorLabels

func GetServerSelectorLabels(conn *v1alpha1.SparkConnect) map[string]string

GetServerSelectorLabels returns the labels used to select server pods owned by SparkConnect.

func GetServerServiceHost

func GetServerServiceHost(conn *v1alpha1.SparkConnect) string

GetServerServiceHost returns the host of the server service for SparkConnect.

func GetServerServiceName

func GetServerServiceName(conn *v1alpha1.SparkConnect) string

GetServerServiceName returns the name of the server service for SparkConnect.

Types

type Options

type Options struct {
	// A list of namespaces that should be watched.
	Namespaces []string
}

Options defines the options of SparkConnect reconciler.

type Reconciler

type Reconciler struct {
	// contains filtered or unexported fields
}

Reconciler reconciles a SparkConnect object.

func NewReconciler

func NewReconciler(
	manager ctrl.Manager,
	scheme *runtime.Scheme,
	client client.Client,
	recorder record.EventRecorder,
	options Options,
) *Reconciler

NewReconciler creates a new SparkConnect Reconciler.

func (*Reconciler) Reconcile

func (r *Reconciler) Reconcile(ctx context.Context, req ctrl.Request) (reconcile.Result, error)

Reconcile implements reconcile.TypedReconciler.

func (*Reconciler) SetupWithManager

func (r *Reconciler) SetupWithManager(mgr ctrl.Manager, options controller.Options) error

SetupWithManager sets up the SparkConnect reconciler with the manager.