errors

Documentation

Index

• func Errorf(c ErrorCode, msgFmt string, args ...interface{}) error
• func IsReconciliationNeeded(err error) bool
• func WrapErrorf(c ErrorCode, cause error, msgFmt string, args ...interface{}) error
• type ErrorCode
• type ErrorMessage
• type FlinkOperatorError
  • func (w *FlinkOperatorError) Error() string
• type FlinkOperatorErrorWithCause
  • func (w *FlinkOperatorErrorWithCause) Cause() error
  • func (w *FlinkOperatorErrorWithCause) Error() string

Functions

func Errorf

func Errorf(c ErrorCode, msgFmt string, args ...interface{}) error

func IsReconciliationNeeded

func IsReconciliationNeeded(err error) bool

func WrapErrorf

func WrapErrorf(c ErrorCode, cause error, msgFmt string, args ...interface{}) error

Types

type ErrorCode

type ErrorCode = string

const (
	IllegalStateError        ErrorCode = "IllegalStateError"
	CausedByError            ErrorCode = "CausedByError"
	BadJobSpecificationError ErrorCode = "BadJobSpecificationError"
	ReconciliationNeeded     ErrorCode = "ReconciliationNeeded"
)

type ErrorMessage

type ErrorMessage = string

type FlinkOperatorError

type FlinkOperatorError struct {
	Code    ErrorCode
	Message ErrorMessage
}

func (*FlinkOperatorError) Error

func (w *FlinkOperatorError) Error() string

type FlinkOperatorErrorWithCause

type FlinkOperatorErrorWithCause struct {
	*FlinkOperatorError
	// contains filtered or unexported fields
}

func (*FlinkOperatorErrorWithCause) Cause

func (w *FlinkOperatorErrorWithCause) Cause() error

func (*FlinkOperatorErrorWithCause) Error

func (w *FlinkOperatorErrorWithCause) Error() string