client

func (*RocketmqClient) CreateConsumerGroup ¶

func (c *RocketmqClient) CreateConsumerGroup(request *rocketmq.CreateConsumerGroupRequest) (*rocketmq.CreateConsumerGroupResponse, error)

创建consumerGroup

func (*RocketmqClient) CreateTopic ¶

func (c *RocketmqClient) CreateTopic(request *rocketmq.CreateTopicRequest) (*rocketmq.CreateTopicResponse, error)

创建指定名称的topic

func (*RocketmqClient) DeleteConsumerGroup ¶

func (c *RocketmqClient) DeleteConsumerGroup(request *rocketmq.DeleteConsumerGroupRequest) (*rocketmq.DeleteConsumerGroupResponse, error)

删除consumerGroup

func (*RocketmqClient) DeleteTopic ¶

func (c *RocketmqClient) DeleteTopic(request *rocketmq.DeleteTopicRequest) (*rocketmq.DeleteTopicResponse, error)

删除单个topic

func (*RocketmqClient) DescribeConsumeTrace ¶

func (c *RocketmqClient) DescribeConsumeTrace(request *rocketmq.DescribeConsumeTraceRequest) (*rocketmq.DescribeConsumeTraceResponse, error)

查询消息消费轨迹（消费组列表）

func (*RocketmqClient) DescribeConsumeTraceDetail ¶

func (c *RocketmqClient) DescribeConsumeTraceDetail(request *rocketmq.DescribeConsumeTraceDetailRequest) (*rocketmq.DescribeConsumeTraceDetailResponse, error)

查询消息消费轨迹（消费者客户端列表）

func (*RocketmqClient) DescribeConsumerAllTopics ¶

func (c *RocketmqClient) DescribeConsumerAllTopics(request *rocketmq.DescribeConsumerAllTopicsRequest) (*rocketmq.DescribeConsumerAllTopicsResponse, error)

消费者订阅过的topic列表，用于重置消费位点

func (*RocketmqClient) DescribeConsumerGroupNames ¶

func (c *RocketmqClient) DescribeConsumerGroupNames(request *rocketmq.DescribeConsumerGroupNamesRequest) (*rocketmq.DescribeConsumerGroupNamesResponse, error)

consumerGroup名称列表，用于查死信消息下拉框

func (*RocketmqClient) DescribeConsumerGroupStatus ¶

func (c *RocketmqClient) DescribeConsumerGroupStatus(request *rocketmq.DescribeConsumerGroupStatusRequest) (*rocketmq.DescribeConsumerGroupStatusResponse, error)

consumerGroup状态详情

func (*RocketmqClient) DescribeConsumerGroups ¶

func (c *RocketmqClient) DescribeConsumerGroups(request *rocketmq.DescribeConsumerGroupsRequest) (*rocketmq.DescribeConsumerGroupsResponse, error)

consumerGroup列表

func (*RocketmqClient) DescribeConsumerSubTopics ¶

func (c *RocketmqClient) DescribeConsumerSubTopics(request *rocketmq.DescribeConsumerSubTopicsRequest) (*rocketmq.DescribeConsumerSubTopicsResponse, error)

consumerGroup在线订阅topic信息

func (*RocketmqClient) DescribeConsumersByTopic ¶

func (c *RocketmqClient) DescribeConsumersByTopic(request *rocketmq.DescribeConsumersByTopicRequest) (*rocketmq.DescribeConsumersByTopicResponse, error)

topic订阅管理列表，显示订阅过该topic的consumerGroup

func (*RocketmqClient) DescribeMessageByMsgId ¶

func (c *RocketmqClient) DescribeMessageByMsgId(request *rocketmq.DescribeMessageByMsgIdRequest) (*rocketmq.DescribeMessageByMsgIdResponse, error)

根据msgId查询消息详情

func (*RocketmqClient) DescribeMessages ¶

func (c *RocketmqClient) DescribeMessages(request *rocketmq.DescribeMessagesRequest) (*rocketmq.DescribeMessagesResponse, error)

查询消息列表

func (*RocketmqClient) DescribeProduceTrace ¶

func (c *RocketmqClient) DescribeProduceTrace(request *rocketmq.DescribeProduceTraceRequest) (*rocketmq.DescribeProduceTraceResponse, error)

查询消息生产轨迹

func (*RocketmqClient) DescribeTopic ¶

func (c *RocketmqClient) DescribeTopic(request *rocketmq.DescribeTopicRequest) (*rocketmq.DescribeTopicResponse, error)

查询topic详情

func (*RocketmqClient) DescribeTopicNames ¶

func (c *RocketmqClient) DescribeTopicNames(request *rocketmq.DescribeTopicNamesRequest) (*rocketmq.DescribeTopicNamesResponse, error)

查询topic列表，用于消息查询接口，下拉框选择topic

func (*RocketmqClient) DescribeTopics ¶

func (c *RocketmqClient) DescribeTopics(request *rocketmq.DescribeTopicsRequest) (*rocketmq.DescribeTopicsResponse, error)

查询topic列表

func (*RocketmqClient) DisableLogger ¶

func (c *RocketmqClient) DisableLogger()

func (*RocketmqClient) ResetOffset ¶

func (c *RocketmqClient) ResetOffset(request *rocketmq.ResetOffsetRequest) (*rocketmq.ResetOffsetResponse, error)

重置消费位点（消费组可以不在线）

func (*RocketmqClient) SendMessage ¶

func (c *RocketmqClient) SendMessage(request *rocketmq.SendMessageRequest) (*rocketmq.SendMessageResponse, error)

发送消息

func (*RocketmqClient) SetConfig ¶

func (c *RocketmqClient) SetConfig(config *core.Config)

func (*RocketmqClient) SetLogger ¶

func (c *RocketmqClient) SetLogger(logger core.Logger)

func (*RocketmqClient) UpdateConsumerGroup ¶

func (c *RocketmqClient) UpdateConsumerGroup(request *rocketmq.UpdateConsumerGroupRequest) (*rocketmq.UpdateConsumerGroupResponse, error)

修改consumerGroup

func (*RocketmqClient) UpdateTopicDescription ¶

func (c *RocketmqClient) UpdateTopicDescription(request *rocketmq.UpdateTopicDescriptionRequest) (*rocketmq.UpdateTopicDescriptionResponse, error)

修改topic描述