Documentation ¶
Index ¶
Constants ¶
View Source
const RabbitExchangeName = ""
Exchange name in RabbitMQ
View Source
const RabbitQueueName = "group_sync"
Queue name in RabbitMQ, used by consumer and producer to exchange message.
Variables ¶
This section is empty.
Functions ¶
func DeclareQueue ¶
Declare a queue in RabbitMQ named RabbitQueueName.
Types ¶
type Message ¶
type Message struct { GroupID string `json:"group_id"` MemberID string `json:"member_id"` Trial int `json:"trial"` }
func (*Message) ExceededTrialLimit ¶
ExceededTrialLimit returns true if Trial is greater than limit, given limit is positive.
Click to show internal directories.
Click to hide internal directories.