headers

var (
	ErrTopicDoesNotExist   = errors.New(errTopicDoesNotExist)
	ErrTopicAlreadyExists  = errors.New(errTopicAlreadyExists)
	ErrInvalidHeaderSizes  = errors.New(errInvalidHeaderSizes)
	ErrConsumerLockFailed  = errors.New(errConsumerLockFailed)
	ErrInvalidMessageID    = errors.New(errInvalidMessageID)
	ErrInvalidMessageLimit = errors.New(errInvalidMessageLimit)
	ErrInvalidTopic        = errors.New(errInvalidTopic)
	ErrInvalidBodyMissing  = errors.New(errInvalidBodyMissing)
	ErrInvalidBodyJSON     = errors.New(errInvalidBodyJSON)
	ErrInvalidWebsocket    = errors.New(errInvalidWebsocket)
	ErrNoContent           = errors.New(errNoContent)
	ErrClosed              = errors.New(errClosed)
	ErrProxyFailed         = errors.New(errProxyFailed)
)