webhook

Documentation

Index

• type Options
• type ScheduledSparkApplicationDefaulter
  • func NewScheduledSparkApplicationDefaulter() *ScheduledSparkApplicationDefaulter
  • func (d *ScheduledSparkApplicationDefaulter) Default(ctx context.Context, obj runtime.Object) error
• type ScheduledSparkApplicationValidator
  • func NewScheduledSparkApplicationValidator() *ScheduledSparkApplicationValidator
  • func (v *ScheduledSparkApplicationValidator) ValidateCreate(ctx context.Context, obj runtime.Object) (warnings admission.Warnings, err error)
  • func (v *ScheduledSparkApplicationValidator) ValidateDelete(ctx context.Context, obj runtime.Object) (warnings admission.Warnings, err error)
  • func (v *ScheduledSparkApplicationValidator) ValidateUpdate(ctx context.Context, oldObj runtime.Object, newObj runtime.Object) (warnings admission.Warnings, err error)
• type SparkApplicationDefaulter
  • func NewSparkApplicationDefaulter() *SparkApplicationDefaulter
  • func (d *SparkApplicationDefaulter) Default(ctx context.Context, obj runtime.Object) error
• type SparkApplicationValidator
  • func NewSparkApplicationValidator(client client.Client, enableResourceQuotaEnforcement bool) *SparkApplicationValidator
  • func (v *SparkApplicationValidator) ValidateCreate(ctx context.Context, obj runtime.Object) (warnings admission.Warnings, err error)
  • func (v *SparkApplicationValidator) ValidateDelete(ctx context.Context, obj runtime.Object) (warnings admission.Warnings, err error)
  • func (v *SparkApplicationValidator) ValidateUpdate(ctx context.Context, oldObj runtime.Object, newObj runtime.Object) (warnings admission.Warnings, err error)
• type SparkPodDefaulter
  • func NewSparkPodDefaulter(client client.Client, namespaces []string) *SparkPodDefaulter
  • func (d *SparkPodDefaulter) Default(ctx context.Context, obj runtime.Object) error

Types

type Options

type Options struct {
	SparkJobNamespaces             []string
	WebhookName                    string
	WebhookPort                    int
	WebhookSecretName              string
	WebhookSecretNamespace         string
	WebhookServiceName             string
	WebhookServiceNamespace        string
	WebhookMetricsBindAddress      string
	EnableResourceQuotaEnforcement bool
}

type ScheduledSparkApplicationDefaulter

type ScheduledSparkApplicationDefaulter struct{}

ScheduledSparkApplicationDefaulter sets default values for a SparkApplication.

func NewScheduledSparkApplicationDefaulter

func NewScheduledSparkApplicationDefaulter() *ScheduledSparkApplicationDefaulter

NewSparkApplicationValidator creates a new SparkApplicationValidator instance.

func (*ScheduledSparkApplicationDefaulter) Default

func (d *ScheduledSparkApplicationDefaulter) Default(ctx context.Context, obj runtime.Object) error

Default implements admission.CustomDefaulter.

type ScheduledSparkApplicationValidator

type ScheduledSparkApplicationValidator struct{}

func NewScheduledSparkApplicationValidator

func NewScheduledSparkApplicationValidator() *ScheduledSparkApplicationValidator

NewScheduledSparkApplicationValidator creates a new ScheduledSparkApplicationValidator instance.

func (*ScheduledSparkApplicationValidator) ValidateCreate

func (v *ScheduledSparkApplicationValidator) ValidateCreate(ctx context.Context, obj runtime.Object) (warnings admission.Warnings, err error)

ValidateCreate implements admission.CustomValidator.

func (*ScheduledSparkApplicationValidator) ValidateDelete

func (v *ScheduledSparkApplicationValidator) ValidateDelete(ctx context.Context, obj runtime.Object) (warnings admission.Warnings, err error)

ValidateDelete implements admission.CustomValidator.

func (*ScheduledSparkApplicationValidator) ValidateUpdate

func (v *ScheduledSparkApplicationValidator) ValidateUpdate(ctx context.Context, oldObj runtime.Object, newObj runtime.Object) (warnings admission.Warnings, err error)

ValidateUpdate implements admission.CustomValidator.

type SparkApplicationDefaulter

type SparkApplicationDefaulter struct{}

SparkApplicationDefaulter sets default values for a SparkApplication.

func NewSparkApplicationDefaulter

func NewSparkApplicationDefaulter() *SparkApplicationDefaulter

NewSparkApplicationValidator creates a new SparkApplicationValidator instance.

func (*SparkApplicationDefaulter) Default

func (d *SparkApplicationDefaulter) Default(ctx context.Context, obj runtime.Object) error

Default implements admission.CustomDefaulter.

type SparkApplicationValidator

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

func NewSparkApplicationValidator

func NewSparkApplicationValidator(client client.Client, enableResourceQuotaEnforcement bool) *SparkApplicationValidator

NewSparkApplicationValidator creates a new SparkApplicationValidator instance.

func (*SparkApplicationValidator) ValidateCreate

func (v *SparkApplicationValidator) ValidateCreate(ctx context.Context, obj runtime.Object) (warnings admission.Warnings, err error)

ValidateCreate implements admission.CustomValidator.

func (*SparkApplicationValidator) ValidateDelete

func (v *SparkApplicationValidator) ValidateDelete(ctx context.Context, obj runtime.Object) (warnings admission.Warnings, err error)

ValidateDelete implements admission.CustomValidator.

func (*SparkApplicationValidator) ValidateUpdate

func (v *SparkApplicationValidator) ValidateUpdate(ctx context.Context, oldObj runtime.Object, newObj runtime.Object) (warnings admission.Warnings, err error)

ValidateUpdate implements admission.CustomValidator.

type SparkPodDefaulter

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

SparkPodDefaulter defaults Spark pods.

func NewSparkPodDefaulter

func NewSparkPodDefaulter(client client.Client, namespaces []string) *SparkPodDefaulter

NewSparkPodDefaulter creates a new SparkPodDefaulter instance.

func (*SparkPodDefaulter) Default

func (d *SparkPodDefaulter) Default(ctx context.Context, obj runtime.Object) error

Default implements admission.CustomDefaulter.