route

type BrokerData struct {
	BrokerName      string         `json:"brokerName"`
	BrokerAddrs     map[int]string `json:"brokerAddrs"`
	BrokerAddrsLock sync.RWMutex   `json:"-"`
}

type BrokerDatas []*BrokerData

type QueueData struct {
	BrokerName     string `json:"brokerName"`
	ReadQueueNums  int    `json:"readQueueNums"`
	WriteQueueNums int    `json:"writeQueueNums"`
	Perm           int    `json:"perm"`
	TopicSynFlag   int    `json:"topicSynFlag"`
}

type QueueDatas []*QueueData

type TopicRouteData struct {
	OrderTopicConf    string              `json:"orderTopicConf"`
	QueueDatas        []*QueueData        `json:"queueDatas"`
	BrokerDatas       []*BrokerData       `json:"brokerDatas"`
	FilterServerTable map[string][]string `json:"filterServerTable"`
}