rocketmq_offset

type ConsumerListByTopic struct {
	Status int                   `json:"status"`
	ErrMsg string                `json:"errMsg"`
	Data   map[string]TopicGroup `json:"data"`
}

type Instance struct {
	config.InstanceConfig
	IgnoredTopics            []string `toml:"ignored_topics"`
	RocketMQConsoleIPAndPort string   `toml:"rocketmq_console_ip_port"`
}

type MsgDiff struct {
	MsgDiffDetails               []*MsgDiffDetail                      `json:"msg_diff_details"`
	MsgDiffTopics                map[string]*MsgDiffTopic              `json:"msg_diff_topics"`
	MsgDiffConsumerGroups        map[string]*MsgDiffConsumerGroup      `json:"msg_diff_consumergroups"`
	MsgDiffTopics_ConsumerGroups map[string]*MsgDiffTopicConsumerGroup `json:"msg_diff_topics_consumergroups"`
	MsgDiffBrokers               map[string]*MsgDiffBroker             `json:"msg_diff_brokers"`
	MsgDiffQueues                map[string]*MsgDiffQueue              `json:"msg_diff_queues"`
	MsgDiffClientInfos           map[string]*MsgDiffClientInfo         `json:"msg_diff_clientinfos"`
}

type MsgDiffBroker struct {
	Broker string `json:"broker"`
	Diff   int    `json:"diff"`
}

type MsgDiffClientInfo struct {
	ConsumerClientIP  string `json:"consumerClientIP"`
	ConsumerClientPID string `json:"consumerClientPID"`
	Diff              int    `json:"diff"`
}

type MsgDiffConsumerGroup struct {
	Diff          int    `json:"diff"`
	ConsumerGroup string `json:"consumerGroup"`
}

type MsgDiffDetail struct {
	Broker            string `json:"broker"`
	QueueId           int    `json:"queueId"`
	ConsumerClientIP  string `json:"consumerClientIP"`
	ConsumerClientPID string `json:"consumerClientPID"`
	Diff              int    `json:"diff"`
	Topic             string `json:"topic"`
	ConsumerGroup     string `json:"consumerGroup"`
}

type MsgDiffQueue struct {
	Broker  string `json:"broker"`
	QueueId int    `json:"queueId"`
	Diff    int    `json:"diff"`
}

type MsgDiffTopic struct {
	Diff  int    `json:"diff"`
	Topic string `json:"topic"`
}

type MsgDiffTopicConsumerGroup struct {
	Diff          int    `json:"diff"`
	Topic         string `json:"topic"`
	ConsumerGroup string `json:"consumerGroup"`
}

type QueueStatInfoList struct {
	BrokerName     string `json:"brokerName"`
	QueueId        int    `json:"queueId"`
	BrokerOffset   int64  `json:"brokerOffset"`
	ConsumerOffset int64  `json:"consumerOffset"`
	ClientInfo     string `json:"clientInfo"`
	LastTimestamp  int64  `json:"lasttimestamp"`
}

type RocketMQ struct {
	config.PluginConfig
	Instances []*Instance `toml:"instances"`
}

type TopicGroup struct {
	Topic             string              `json:"topic"`
	DiffTotal         int                 `json:"diffTotal"`
	LastTimestamp     int64               `json:"lastTimestamp"`
	QueueStatInfoList []QueueStatInfoList `json:"queueStatInfoList"`
}

type TopicList struct {
	Status int           `json:"status"`
	Data   TopicListData `json:"data"`
	ErrMsg string        `json:"errMsg"`
}

type TopicListData struct {
	TopicList  []string `json:"topicList"`
	BrokerAddr string   `json:"brokerAddr"`
}