Versions in this module Expand all Collapse all v0 v0.1.0 Aug 4, 2025 Changes in this version + var ErrAlreadySubscribed = errors.New("client already subscribed") + var ErrBackpressure = errors.New("system under load") + var ErrCircuitOpen = errors.New("circuit breaker open") + var ErrClientExists = errors.New("client already exists") + var ErrClientNotActive = errors.New("client not active") + var ErrClientNotFound = errors.New("client not registered") + var ErrInvalidMessage = errors.New("invalid message format") + var ErrMessageExpired = errors.New("message TTL exceeded") + var ErrMessageNotFound = errors.New("message not found") + var ErrMessageTooLarge = errors.New("message exceeds size limit") + var ErrNotSubscribed = errors.New("client not subscribed to topic") + var ErrQueueEmpty = errors.New("queue is empty") + var ErrQueueExists = errors.New("queue already exists") + var ErrQueueFull = errors.New("queue at capacity") + var ErrQueueNotFound = errors.New("queue not found") + var ErrShuttingDown = errors.New("system shutting down") + var ErrStorageFailure = errors.New("storage operation failed") + var ErrTimeout = errors.New("operation timed out") + var ErrTransactionFailed = errors.New("transaction failed") + func IsFatal(err error) bool + func IsRetryable(err error) bool + type AMQError struct + Cause error + Code ErrorCode + Component string + Details interface{} + Message string + Timestamp time.Time + func NewAMQError(code ErrorCode, component, message string) *AMQError + func (e *AMQError) Error() string + func (e *AMQError) Unwrap() error + func (e *AMQError) WithCause(cause error) *AMQError + func (e *AMQError) WithDetails(details interface{}) *AMQError + type APIError struct + Code int + Message string + StatusCode int + func NewAPIError(statusCode int, message string) *APIError + func (e *APIError) Error() string + type ErrorCode int + const CodeAuthFailed + const CodeBackpressure + const CodeCircuitOpen + const CodeClientExists + const CodeClientNotActive + const CodeClientNotFound + const CodeInvalidMessage + const CodeMessageExpired + const CodeMessageNotFound + const CodeMessageTooLarge + const CodeQueueEmpty + const CodeQueueExists + const CodeQueueFull + const CodeQueueNotFound + const CodeRateLimited + const CodeShuttingDown + const CodeStorageFailure + const CodeTimeout + const CodeTransactionFailed + type ErrorResponse struct + Code ErrorCode + Details interface{} + Error string + RequestID string + Timestamp time.Time + func NewErrorResponse(err error, requestID string) *ErrorResponse
Go to main page