errors

Documentation

Index

• type SourceAckErr
  • func (e *SourceAckErr) Error() string
  • func (e *SourceAckErr) Is(target error) bool
  • func (e *SourceAckErr) IsRetryable() bool
• type SourcePendingErr
  • func (e *SourcePendingErr) Error() string
  • func (e *SourcePendingErr) Is(target error) bool
  • func (e *SourcePendingErr) IsRetryable() bool
• type SourceReadErr
  • func (e *SourceReadErr) Error() string
  • func (e *SourceReadErr) Is(target error) bool
  • func (e *SourceReadErr) IsRetryable() bool

Types

type SourceAckErr

type SourceAckErr struct {
	Message   string
	Retryable bool
}

func (*SourceAckErr) Error

func (e *SourceAckErr) Error() string

func (*SourceAckErr) Is

func (e *SourceAckErr) Is(target error) bool

func (*SourceAckErr) IsRetryable

func (e *SourceAckErr) IsRetryable() bool

IsRetryable is true if the error is retryable

type SourcePendingErr

type SourcePendingErr struct {
	Message   string
	Retryable bool
}

func (*SourcePendingErr) Error

func (e *SourcePendingErr) Error() string

func (*SourcePendingErr) Is

func (e *SourcePendingErr) Is(target error) bool

func (*SourcePendingErr) IsRetryable

func (e *SourcePendingErr) IsRetryable() bool

IsRetryable is true if the error is retryable

type SourceReadErr

type SourceReadErr struct {
	Message   string
	Retryable bool
}

SourceReadErr represents any source read related error

func (*SourceReadErr) Error

func (e *SourceReadErr) Error() string

func (*SourceReadErr) Is

func (e *SourceReadErr) Is(target error) bool

func (*SourceReadErr) IsRetryable

func (e *SourceReadErr) IsRetryable() bool

IsRetryable is true if the error is retryable