sparkapplication

Jun 26, 2025

Changes in this version

type Options

+ IngressAnnotations map[string]string

+ IngressTLS []networkingv1.IngressTLS

May 29, 2025

Changes in this version

+ type EventFilter struct

+ func NewSparkApplicationEventFilter(client client.Client, recorder record.EventRecorder, namespaces []string) *EventFilter

+ func (f *EventFilter) Create(e event.CreateEvent) bool

+ func (f *EventFilter) Delete(e event.DeleteEvent) bool

+ func (f *EventFilter) Generic(e event.GenericEvent) bool

+ func (f *EventFilter) Update(e event.UpdateEvent) bool

+ type EventHandler struct

+ func NewSparkApplicationEventHandler(metrics *metrics.SparkApplicationMetrics) *EventHandler

+ func (h *EventHandler) Create(ctx context.Context, event event.CreateEvent, ...)

+ func (h *EventHandler) Delete(ctx context.Context, event event.DeleteEvent, ...)

+ func (h *EventHandler) Generic(ctx context.Context, event event.GenericEvent, ...)

+ func (h *EventHandler) Update(ctx context.Context, event event.UpdateEvent, ...)

+ type Options struct

+ DefaultBatchScheduler string

+ DriverPodCreationGracePeriod time.Duration

+ EnableUIService bool

+ IngressClassName string

+ IngressURLFormat string

+ KubeSchedulerNames []string

+ MaxTrackedExecutorPerApp int

+ Namespaces []string

+ SparkApplicationMetrics *metrics.SparkApplicationMetrics

+ SparkExecutorMetrics *metrics.SparkExecutorMetrics

+ type Reconciler struct

+ func NewReconciler(manager ctrl.Manager, scheme *runtime.Scheme, client client.Client, ...) *Reconciler

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

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

+ type SparkApplicationSubmitter interface

+ Submit func(ctx context.Context, app *v1beta2.SparkApplication) error

+ type SparkIngress struct

+ type SparkPodEventHandler struct

+ func NewSparkPodEventHandler(client client.Client, metrics *metrics.SparkExecutorMetrics) *SparkPodEventHandler

+ func (h *SparkPodEventHandler) Create(ctx context.Context, event event.CreateEvent, ...)

+ func (h *SparkPodEventHandler) Delete(ctx context.Context, event event.DeleteEvent, ...)

+ func (h *SparkPodEventHandler) Generic(ctx context.Context, event event.GenericEvent, ...)

+ func (h *SparkPodEventHandler) Update(ctx context.Context, event event.UpdateEvent, ...)

+ type SparkService struct

+ type SparkSubmitter struct

+ func (*SparkSubmitter) Submit(ctx context.Context, app *v1beta2.SparkApplication) error

+ type Validator struct

+ func (s *Validator) ValidateCreate(_ context.Context, _ runtime.Object) (admission.Warnings, error)

+ func (s *Validator) ValidateDelete(_ context.Context, _ runtime.Object) (admission.Warnings, error)

+ func (s *Validator) ValidateUpdate(_ context.Context, _ runtime.Object, _ runtime.Object) (admission.Warnings, error)