Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ErrConsumerStopped = errors.New("the server has been stopped")
ErrConsumerStopped indicates that the operation is now illegal because of the consumer being stopped.
View Source
var ErrStopTaskDeletion = errors.New("task should not be deleted")
ErrStopTaskDeletion indicates that the task should not be deleted from source after task failure
Functions ¶
This section is empty.
Types ¶
type ErrCouldNotUnmarshalTaskSignature ¶
type ErrCouldNotUnmarshalTaskSignature struct {
// contains filtered or unexported fields
}
ErrCouldNotUnmarshalTaskSignature ...
func NewErrCouldNotUnmarshalTaskSignature ¶
func NewErrCouldNotUnmarshalTaskSignature(msg []byte, err error) ErrCouldNotUnmarshalTaskSignature
NewErrCouldNotUnmarshalTaskSignature returns new ErrCouldNotUnmarshalTaskSignature instance
func (ErrCouldNotUnmarshalTaskSignature) Error ¶
func (e ErrCouldNotUnmarshalTaskSignature) Error() string
Error implements the error interface
Click to show internal directories.
Click to hide internal directories.