Function maybeErrorHandler

pkg/controller/pipe/error_handler.go:33–70

maybeErrorHandler will return a Binding mapping a DeadLetterChannel, a Log or a None Error Handler. If the bindings has no URI, then, you can assume it's a none Error Handler.

(errHandlConf *v1.ErrorHandlerSpec, bindingContext bindings.BindingContext)

// maybeErrorHandler will return a Binding mapping a DeadLetterChannel, a Log or a None Error Handler.
// If the bindings has no URI, then, you can assume it's a none Error Handler.
func maybeErrorHandler(errHandlConf *v1.ErrorHandlerSpec, bindingContext bindings.BindingContext) (*bindings.Binding, error) {
	if errHandlConf == nil {
		return nil, nil
	}

	var errorHandlerBinding *bindings.Binding

	errorHandlerSpec, err := parseErrorHandler(&errHandlConf.RawMessage)
	if err != nil {
		return nil, fmt.Errorf("could not parse error handler: %w", err)
	}
	// We need to get the translated URI from any referenced resource (ie, kamelets)
	if errorHandlerSpec.Type() == v1.ErrorHandlerTypeSink {
		errorHandlerBinding, err = bindings.Translate(
			bindingContext,
			bindings.EndpointContext{Type: v1.EndpointTypeErrorHandler},
			*errorHandlerSpec.Endpoint(),
		)
		if err != nil {
			return nil, fmt.Errorf("could not determine error handler URI: %w", err)
		}
	} else {
		// Create a new binding otherwise in order to store error handler application properties
		errorHandlerBinding = &bindings.Binding{
			ApplicationProperties: make(map[string]string),
		}
		if errorHandlerSpec.Type() == v1.ErrorHandlerTypeLog {
			errorHandlerBinding.URI = defaultCamelErrorHandler
		}
	}

	err = setErrorHandlerConfiguration(errorHandlerBinding, errorHandlerSpec)
	if err != nil {
		return nil, fmt.Errorf("could not set integration error handler: %w", err)
	}

	return errorHandlerBinding, nil
}

func parseErrorHandler(rawMessage *v1.RawMessage) (v1.ErrorHandler, error) {
	var properties map[v1.ErrorHandlerType]v1.RawMessage