error

Documentation

Index

• type ErrKind
  • func (ek ErrKind) String() string
• type UDFError
  • func FromError(err error) (udfErr *UDFError, ok bool)
  • func New(kind ErrKind, msg string) *UDFError
  • func (e *UDFError) Error() string
  • func (e *UDFError) ErrorKind() ErrKind
  • func (e *UDFError) ErrorMessage() string

Types

type ErrKind

type ErrKind int16

ErrKind represents if the error is retryable

const (
	Retryable    ErrKind = iota // The error is retryable
	NonRetryable                // The error is non-retryable
	Canceled                    // Request canceled
	Unknown                     // Unknown err kind
)

func (ErrKind) String

func (ek ErrKind) String() string

type UDFError

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

UDFError is returned to the main numaflow indicates the status of the error

func FromError

func FromError(err error) (udfErr *UDFError, ok bool)

FromError gets error information from the UDFError

func New

func New(kind ErrKind, msg string) *UDFError

func (*UDFError) Error

func (e *UDFError) Error() string

func (*UDFError) ErrorKind

func (e *UDFError) ErrorKind() ErrKind

func (*UDFError) ErrorMessage

func (e *UDFError) ErrorMessage() string