kafkacontroller

Documentation

Index

• func SetupController(mgr ctrl.Manager) error
• func SetupWebhook(mgr ctrl.Manager) error
• type Validator
  • func (v *Validator) ValidateCreate(ctx context.Context, obj runtime.Object) (admission.Warnings, error)
  • func (v *Validator) ValidateDelete(_ context.Context, _ runtime.Object) (admission.Warnings, error)
  • func (v *Validator) ValidateUpdate(_ context.Context, oldObj, newObj runtime.Object) (admission.Warnings, error)

Functions

func SetupController

func SetupController(mgr ctrl.Manager) error

SetupController adds a controller that reconciles kafka resources.

func SetupWebhook

func SetupWebhook(mgr ctrl.Manager) error

SetupWebhook adds a webhook for kafka resources.

Types

type Validator

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

Validator validates kafka admission requests.

func (*Validator) ValidateCreate

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

ValidateCreate validates the spec of a created kafka resource.

func (*Validator) ValidateDelete

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

ValidateDelete validates a delete. Currently does not validate anything.

func (*Validator) ValidateUpdate

func (v *Validator) ValidateUpdate(_ context.Context, oldObj, newObj runtime.Object) (admission.Warnings, error)

ValidateUpdate validates the spec of an updated kafka resource and checks that no immutable field has been modified.