error

Documentation

Index

• func ToUDFErr(name string, err error) error
• 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

Functions

func ToUDFErr

func ToUDFErr(name string, err error) error

ToUDFErr converts gRPC error to UDF Error

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