webhook

Documentation

Index

• func ConvertFrontendService(obj *v1alpha1.RisingWave)
• func ConvertGlobalConfig(obj *v1alpha1.RisingWave)
• func ConvertGlobalImage(obj *v1alpha1.RisingWave)
• func ConvertNodeGroups(obj *v1alpha1.RisingWave)
• func ConvertStorages(obj *v1alpha1.RisingWave)
• func ConvertToV1alpha2Features(obj *v1alpha1.RisingWave)
• func NewRisingWaveMutatingWebhook() webhook.CustomDefaulter
• func NewRisingWaveScaleViewMutatingWebhook(client client.Reader) webhook.CustomDefaulter
• func NewRisingWaveScaleViewValidatingWebhook(client client.Reader) webhook.CustomValidator
• func NewRisingWaveValidatingWebhook(openKruiseAvailable bool) webhook.CustomValidator
• func SetupWebhooksWithManager(mgr ctrl.Manager, openKruiseAvailable bool) error
• type RisingWaveMutatingWebhook
  • func (m *RisingWaveMutatingWebhook) Default(ctx context.Context, obj runtime.Object) error
• type RisingWaveScaleViewMutatingWebhook
  • func (w *RisingWaveScaleViewMutatingWebhook) Default(ctx context.Context, obj runtime.Object) error
• type RisingWaveScaleViewValidatingWebhook
  • func (w *RisingWaveScaleViewValidatingWebhook) ValidateCreate(ctx context.Context, obj runtime.Object) (warnings admission.Warnings, err error)
  • func (w *RisingWaveScaleViewValidatingWebhook) ValidateDelete(ctx context.Context, obj runtime.Object) (warnings admission.Warnings, err error)
  • func (w *RisingWaveScaleViewValidatingWebhook) ValidateUpdate(ctx context.Context, oldObj, newObj runtime.Object) (warnings admission.Warnings, err error)
• type RisingWaveValidatingWebhook
  • func (v *RisingWaveValidatingWebhook) ValidateCreate(ctx context.Context, obj runtime.Object) (warnings admission.Warnings, err error)
  • func (v *RisingWaveValidatingWebhook) ValidateDelete(ctx context.Context, obj runtime.Object) (warnings admission.Warnings, err error)
  • func (v *RisingWaveValidatingWebhook) ValidateUpdate(ctx context.Context, oldObj runtime.Object, newObj runtime.Object) (warnings admission.Warnings, err error)

Functions

func ConvertFrontendService

func ConvertFrontendService(obj *v1alpha1.RisingWave)

ConvertFrontendService converts v1alpha1 service type and service meta. nolint

func ConvertGlobalConfig

func ConvertGlobalConfig(obj *v1alpha1.RisingWave)

ConvertGlobalConfig converts the global config to the new global config.

func ConvertGlobalImage

func ConvertGlobalImage(obj *v1alpha1.RisingWave)

ConvertGlobalImage converts v1alpha1 global image. nolint

func ConvertNodeGroups

func ConvertNodeGroups(obj *v1alpha1.RisingWave)

ConvertNodeGroups converts the old node groups to the new node groups. nolint

func ConvertStorages

func ConvertStorages(obj *v1alpha1.RisingWave)

ConvertStorages converts v1alpha1 storages. nolint

func ConvertToV1alpha2Features

func ConvertToV1alpha2Features(obj *v1alpha1.RisingWave)

ConvertToV1alpha2Features converts v1alpha1 features to v1alpha2 features.

func NewRisingWaveMutatingWebhook

func NewRisingWaveMutatingWebhook() webhook.CustomDefaulter

NewRisingWaveMutatingWebhook returns a new mutating webhook for RisingWaves.

func NewRisingWaveScaleViewMutatingWebhook

func NewRisingWaveScaleViewMutatingWebhook(client client.Reader) webhook.CustomDefaulter

NewRisingWaveScaleViewMutatingWebhook returns a new mutating webhook for RisingWaveScaleViews.

func NewRisingWaveScaleViewValidatingWebhook

func NewRisingWaveScaleViewValidatingWebhook(client client.Reader) webhook.CustomValidator

NewRisingWaveScaleViewValidatingWebhook returns a new validator for RisingWaveScaleViews.

func NewRisingWaveValidatingWebhook

func NewRisingWaveValidatingWebhook(openKruiseAvailable bool) webhook.CustomValidator

NewRisingWaveValidatingWebhook returns a new validator for the RisingWave. The behavior differs on different values of the openKruiseAvailable.

func SetupWebhooksWithManager

func SetupWebhooksWithManager(mgr ctrl.Manager, openKruiseAvailable bool) error

SetupWebhooksWithManager set up the webhooks.

Types

type RisingWaveMutatingWebhook

type RisingWaveMutatingWebhook struct{}

RisingWaveMutatingWebhook is the mutating webhook for RisingWaves.

func (*RisingWaveMutatingWebhook) Default

func (m *RisingWaveMutatingWebhook) Default(ctx context.Context, obj runtime.Object) error

Default implements admission.CustomDefaulter.

type RisingWaveScaleViewMutatingWebhook

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

RisingWaveScaleViewMutatingWebhook is the mutating webhook for RisingWaveScaleViews.

func (*RisingWaveScaleViewMutatingWebhook) Default

func (w *RisingWaveScaleViewMutatingWebhook) Default(ctx context.Context, obj runtime.Object) error

Default implements the webhook.CustomDefaulter.

type RisingWaveScaleViewValidatingWebhook

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

RisingWaveScaleViewValidatingWebhook is the validating webhook for RisingWaveScaleView.

func (*RisingWaveScaleViewValidatingWebhook) ValidateCreate

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

ValidateCreate implements the webhook.CustomValidator.

func (*RisingWaveScaleViewValidatingWebhook) ValidateDelete

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

ValidateDelete implements the webhook.CustomValidator.

func (*RisingWaveScaleViewValidatingWebhook) ValidateUpdate

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

ValidateUpdate implements the webhook.CustomValidator.

type RisingWaveValidatingWebhook

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

RisingWaveValidatingWebhook is the validating webhook for RisingWaves.

func (*RisingWaveValidatingWebhook) ValidateCreate

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

ValidateCreate implements admission.CustomValidator.

func (*RisingWaveValidatingWebhook) ValidateDelete

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

ValidateDelete implements admission.CustomValidator.

func (*RisingWaveValidatingWebhook) ValidateUpdate

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

ValidateUpdate implements admission.CustomValidator.