logpipeline

Documentation

Index

• Constants
• type DryRunner
• type ValidatingWebhookHandler
  • func NewValidatingWebhookHandler(client client.Client, inputValidator validation.InputValidator, ...) *ValidatingWebhookHandler
  • func (v *ValidatingWebhookHandler) Handle(ctx context.Context, req admission.Request) admission.Response
  • func (v *ValidatingWebhookHandler) InjectDecoder(d *admission.Decoder) error

Constants

const (
	StatusReasonConfigurationError = "InvalidConfiguration"
)

Types

type DryRunner

type DryRunner interface {
	RunPipeline(ctx context.Context, pipeline *telemetryv1alpha1.LogPipeline) error
}

type ValidatingWebhookHandler

type ValidatingWebhookHandler struct {
	client.Client
	// contains filtered or unexported fields
}

+kubebuilder:webhook:path=/validate-logpipeline,mutating=false,failurePolicy=fail,sideEffects=None,groups=telemetry.kyma-project.io,resources=logpipelines,verbs=create;update,versions=v1alpha1,name=vlogpipeline.kb.io,admissionReviewVersions=v1

func NewValidatingWebhookHandler

func NewValidatingWebhookHandler(
	client client.Client,
	inputValidator validation.InputValidator,
	variablesValidator validation.VariablesValidator,
	filterValidator validation.FilterValidator,
	maxPipelinesValidator validation.MaxPipelinesValidator,
	outputValidator validation.OutputValidator,
	fileValidator validation.FilesValidator,
	dryRunner DryRunner,
) *ValidatingWebhookHandler

func (*ValidatingWebhookHandler) Handle

func (v *ValidatingWebhookHandler) Handle(ctx context.Context, req admission.Request) admission.Response

func (*ValidatingWebhookHandler) InjectDecoder

func (v *ValidatingWebhookHandler) InjectDecoder(d *admission.Decoder) error