rocketmq_offset

Documentation

Index

• func GetTopicNameList(rocketmqConsoleIPAndPort string) []string
• type ConsumerListByTopic
  • func GetConsumerListByTopic(rocketmqConsoleIPAndPort string, topicName string) *ConsumerListByTopic
• type Instance
  • func (ins *Instance) Gather(slist *types.SampleList)
  • func (ins *Instance) Init() error
• type MsgDiff
• type MsgDiffBroker
• type MsgDiffClientInfo
• type MsgDiffConsumerGroup
• type MsgDiffDetail
• type MsgDiffQueue
• type MsgDiffTopic
• type MsgDiffTopicConsumerGroup
• type QueueStatInfoList
• type RocketMQ
  • func (pt *RocketMQ) Clone() inputs.Input
  • func (pt *RocketMQ) GetInstances() []inputs.Instance
  • func (pt *RocketMQ) Name() string
• type TopicGroup
• type TopicList
• type TopicListData

Functions

func GetTopicNameList

func GetTopicNameList(rocketmqConsoleIPAndPort string) []string

Types

type ConsumerListByTopic

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

func GetConsumerListByTopic

func GetConsumerListByTopic(rocketmqConsoleIPAndPort string, topicName string) *ConsumerListByTopic

type Instance

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

func (*Instance) Gather

func (ins *Instance) Gather(slist *types.SampleList)

func (*Instance) Init

func (ins *Instance) Init() error

type MsgDiff

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

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

type MsgDiffClientInfo

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

type MsgDiffConsumerGroup

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

type MsgDiffDetail

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

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

type MsgDiffTopic

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

type MsgDiffTopicConsumerGroup

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

type QueueStatInfoList

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

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

func (*RocketMQ) Clone

func (pt *RocketMQ) Clone() inputs.Input

func (*RocketMQ) GetInstances

func (pt *RocketMQ) GetInstances() []inputs.Instance

func (*RocketMQ) Name

func (pt *RocketMQ) Name() string

type TopicGroup

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

type TopicList

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

type TopicListData

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