Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ( ErrRequestTimeout = errors.New("request timeout") ErrMQEmpty = errors.New("MessageQueue is nil") ErrOffset = errors.New("offset < 0") ErrNumbers = errors.New("numbers < 0") ErrEmptyTopic = errors.New("empty topic") ErrEmptyNameSrv = errors.New("empty namesrv") ErrEmptyGroupID = errors.New("empty group id") ErrTestMin = errors.New("test minutes must be positive integer") ErrOperationInterval = errors.New("operation interval must be positive integer") ErrMessageBody = errors.New("message body size must be positive integer") ErrEmptyExpression = errors.New("empty expression") ErrCreated = errors.New("consumer group has been created") ErrBrokerNotFound = errors.New("broker can not found") ErrStartTopic = errors.New("cannot subscribe topic since client either failed to start or has been shutdown.") ErrResponse = errors.New("response error") ErrCompressLevel = errors.New("unsupported compress level") ErrUnknownIP = errors.New("unknown IP address") ErrService = errors.New("service close is not running, please check") ErrTopicNotExist = errors.New("topic not exist") ErrNotExisted = errors.New("not existed") ErrNoNameserver = errors.New("nameServerAddrs can't be empty.") ErrMultiIP = errors.New("multiple IP addr does not support") ErrIllegalIP = errors.New("IP addr error") ErrTopicEmpty = errors.New("topic is nil") ErrMessageEmpty = errors.New("message is nil") ErrNotRunning = errors.New("producer not started") ErrPullConsumer = errors.New("pull consumer has not supported") ErrProducerCreated = errors.New("producer group has been created") ErrMultipleTopics = errors.New("the topic of the messages in one batch should be the same") )
Functions ¶
This section is empty.
Types ¶
This section is empty.
Click to show internal directories.
Click to hide internal directories.