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 ErrCouldNotUnmarshaTaskSignature ¶
type ErrCouldNotUnmarshaTaskSignature struct {
// contains filtered or unexported fields
}
ErrCouldNotUnmarshaTaskSignature ...
func NewErrCouldNotUnmarshaTaskSignature ¶
func NewErrCouldNotUnmarshaTaskSignature(msg []byte, err error) ErrCouldNotUnmarshaTaskSignature
NewErrCouldNotUnmarshaTaskSignature returns new ErrCouldNotUnmarshaTaskSignature instance
func (ErrCouldNotUnmarshaTaskSignature) Error ¶
func (e ErrCouldNotUnmarshaTaskSignature) Error() string
Error implements the error interface
Click to show internal directories.
Click to hide internal directories.