org.joyqueue.handler.routing.command.monitor

类 BrokerMonitorCommand

java.lang.Object

org.joyqueue.handler.routing.command.monitor.BrokerMonitorCommand

所有已实现的接口:

com.jd.laf.extension.Prototype, com.jd.laf.extension.Type<String>, com.jd.laf.web.vertx.Command<com.jd.laf.web.vertx.response.Response>, com.jd.laf.web.vertx.pool.Poolable, Cloneable

public class BrokerMonitorCommand
extends Object
implements com.jd.laf.web.vertx.Command<com.jd.laf.web.vertx.response.Response>, com.jd.laf.web.vertx.pool.Poolable

嵌套类概要

从接口继承的嵌套类/接口 com.jd.laf.web.vertx.Command

com.jd.laf.web.vertx.Command.EmptyContinue, com.jd.laf.web.vertx.Command.EmptyHold, com.jd.laf.web.vertx.Command.Result, com.jd.laf.web.vertx.Command.ResultType

字段概要

从接口继承的字段 com.jd.laf.web.vertx.Command

RESULT

构造器概要

构造器

构造器和说明
BrokerMonitorCommand()

方法概要

限定符和类型	方法和说明
com.jd.laf.web.vertx.response.Response	archiveState(org.joyqueue.domain.Broker broker) 指定 broker archive汇总信息
com.jd.laf.web.vertx.response.Response	brokerConnectionsMonitor(org.joyqueue.model.QPageQuery<org.joyqueue.model.query.QMonitor> qPageQuery) 指定broker 连接 监控
com.jd.laf.web.vertx.response.Response	brokerMonitor(org.joyqueue.model.QPageQuery<org.joyqueue.model.query.QMonitor> qPageQuery) 指定topic、app、broker 生产或者消费 监控
void	clean()
com.jd.laf.web.vertx.response.Response	coordinator(org.joyqueue.model.domain.Subscribe subscribe) 指定 app 的协调者信息
com.jd.laf.web.vertx.response.Response	coordinatorGroupExpiredMember(org.joyqueue.model.domain.Subscribe subscribe) 指定 app 的协调者信息
com.jd.laf.web.vertx.response.Response	coordinatorGroupMember(org.joyqueue.model.domain.Subscribe subscribe) 指定 app,topic 消费组member
com.jd.laf.web.vertx.response.Response	deleteGarbageFile(Integer brokerId, String fileName, boolean retain) broker启动信息
com.jd.laf.web.vertx.response.Response	execute()
com.jd.laf.web.vertx.response.Response	find(org.joyqueue.model.domain.Subscribe subscribe) topic and app 生产或者消费监控汇总信息
com.jd.laf.web.vertx.response.Response	findBrokerDetail(Long brokerId) broker监控
com.jd.laf.web.vertx.response.Response	findBrokerMetadata(Long brokerId, String topicFullName, Integer group) TODO 改成post方法,topicFullName可能存在 broker启动信息
com.jd.laf.web.vertx.response.Response	findClients(org.joyqueue.model.domain.Subscribe subscribe) 指定topic、app 生产或者消费Client监控汇总信息
com.jd.laf.web.vertx.response.Response	findConnectionOnBroker(org.joyqueue.model.domain.Subscribe subscribe) 指定topic、app 在broker 上的连接数
com.jd.laf.web.vertx.response.Response	findMonitorOnBroker(org.joyqueue.model.domain.Subscribe subscribe) 指定topic、app 在broker 上的生产或者消费监控
com.jd.laf.web.vertx.response.Response	findMonitorOnPartition(org.joyqueue.model.domain.Subscribe subscribe) 指定topic、app 在partition 上的生产或者消费监控
com.jd.laf.web.vertx.response.Response	findMonitorOnPartitionGroupDetailForTopicApp(org.joyqueue.model.query.QPartitionGroupMonitor partitionGroupMonitor) 指定topic、app 生产或者消费 partition groups监控汇总信息
com.jd.laf.web.vertx.response.Response	findMonitorOnPartitionGroups(org.joyqueue.model.domain.Subscribe subscribe) 指定topic、app 在partition groups 上的生产或者消费监控
com.jd.laf.web.vertx.response.Response	findMonitorOnPartitionsGroupsForTopicApp(org.joyqueue.model.domain.Subscribe subscribe) 指定topic、app 生产或者消费 partition groups监控汇总信息
com.jd.laf.web.vertx.response.Response	findPartitionGroupMetric(org.joyqueue.model.query.QPartitionGroupMonitor partitionGroupMonitor) 获取详情
com.jd.laf.web.vertx.response.Response	partitionGroupMonitor(org.joyqueue.model.QPageQuery<org.joyqueue.model.query.QMonitor> qPageQuery) 指定topic、app、broker 生产或者消费 partitionGroup 监控
com.jd.laf.web.vertx.response.Response	previewMessage(org.joyqueue.model.domain.Subscribe subscribe) 指定topic、app 生产或者消费Client监控汇总信息
com.jd.laf.web.vertx.response.Response	startInfo(Long brokerId) broker启动信息
com.jd.laf.web.vertx.response.Response	storeTreeView(Integer brokerId, boolean recursive) broker启动信息
com.jd.laf.web.vertx.response.Response	viewMessage(org.joyqueue.model.domain.Subscribe subscribe, String partition, String index, String timestamp) 指定topic、app 生产或者消费Client监控汇总信息

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

从接口继承的方法 com.jd.laf.web.vertx.Command

type

构造器详细资料

BrokerMonitorCommand

public BrokerMonitorCommand()

方法详细资料

execute

public com.jd.laf.web.vertx.response.Response execute()
                                               throws Exception

指定者:

execute 在接口中 com.jd.laf.web.vertx.Command<com.jd.laf.web.vertx.response.Response>

抛出:

Exception

find

public com.jd.laf.web.vertx.response.Response find(org.joyqueue.model.domain.Subscribe subscribe)

topic and app 生产或者消费监控汇总信息

findMonitorOnPartition

public com.jd.laf.web.vertx.response.Response findMonitorOnPartition(org.joyqueue.model.domain.Subscribe subscribe)

指定topic、app 在partition 上的生产或者消费监控

findMonitorOnPartitionGroups

public com.jd.laf.web.vertx.response.Response findMonitorOnPartitionGroups(org.joyqueue.model.domain.Subscribe subscribe)

指定topic、app 在partition groups 上的生产或者消费监控

findMonitorOnBroker

public com.jd.laf.web.vertx.response.Response findMonitorOnBroker(org.joyqueue.model.domain.Subscribe subscribe)

指定topic、app 在broker 上的生产或者消费监控

findConnectionOnBroker

public com.jd.laf.web.vertx.response.Response findConnectionOnBroker(org.joyqueue.model.domain.Subscribe subscribe)

指定topic、app 在broker 上的连接数

findClients

public com.jd.laf.web.vertx.response.Response findClients(org.joyqueue.model.domain.Subscribe subscribe)

指定topic、app 生产或者消费Client监控汇总信息

brokerMonitor

public com.jd.laf.web.vertx.response.Response brokerMonitor(org.joyqueue.model.QPageQuery<org.joyqueue.model.query.QMonitor> qPageQuery)

指定topic、app、broker 生产或者消费 监控

partitionGroupMonitor

public com.jd.laf.web.vertx.response.Response partitionGroupMonitor(org.joyqueue.model.QPageQuery<org.joyqueue.model.query.QMonitor> qPageQuery)

指定topic、app、broker 生产或者消费 partitionGroup 监控

brokerConnectionsMonitor

public com.jd.laf.web.vertx.response.Response brokerConnectionsMonitor(org.joyqueue.model.QPageQuery<org.joyqueue.model.query.QMonitor> qPageQuery)

指定broker 连接 监控

findMonitorOnPartitionsGroupsForTopicApp

public com.jd.laf.web.vertx.response.Response findMonitorOnPartitionsGroupsForTopicApp(org.joyqueue.model.domain.Subscribe subscribe)

指定topic、app 生产或者消费 partition groups监控汇总信息

findMonitorOnPartitionGroupDetailForTopicApp

public com.jd.laf.web.vertx.response.Response findMonitorOnPartitionGroupDetailForTopicApp(org.joyqueue.model.query.QPartitionGroupMonitor partitionGroupMonitor)

指定topic、app 生产或者消费 partition groups监控汇总信息

previewMessage

public com.jd.laf.web.vertx.response.Response previewMessage(org.joyqueue.model.domain.Subscribe subscribe)

指定topic、app 生产或者消费Client监控汇总信息

viewMessage

public com.jd.laf.web.vertx.response.Response viewMessage(org.joyqueue.model.domain.Subscribe subscribe,
                                                          String partition,
                                                          String index,
                                                          String timestamp)

指定topic、app 生产或者消费Client监控汇总信息

archiveState

public com.jd.laf.web.vertx.response.Response archiveState(org.joyqueue.domain.Broker broker)

指定 broker archive汇总信息

参数:

broker - target broker

coordinator

public com.jd.laf.web.vertx.response.Response coordinator(org.joyqueue.model.domain.Subscribe subscribe)

指定 app 的协调者信息

参数:

subscribe -

coordinatorGroupMember

public com.jd.laf.web.vertx.response.Response coordinatorGroupMember(org.joyqueue.model.domain.Subscribe subscribe)

指定 app,topic 消费组member

参数:

subscribe -

coordinatorGroupExpiredMember

public com.jd.laf.web.vertx.response.Response coordinatorGroupExpiredMember(org.joyqueue.model.domain.Subscribe subscribe)

指定 app 的协调者信息

参数:

subscribe -

findPartitionGroupMetric

public com.jd.laf.web.vertx.response.Response findPartitionGroupMetric(org.joyqueue.model.query.QPartitionGroupMonitor partitionGroupMonitor)

获取详情

参数:

partitionGroupMonitor -

返回:

findBrokerDetail

public com.jd.laf.web.vertx.response.Response findBrokerDetail(Long brokerId)

broker监控

参数:

brokerId -

返回:

startInfo

public com.jd.laf.web.vertx.response.Response startInfo(Long brokerId)
                                                 throws Exception

broker启动信息

参数:

brokerId -

返回:

抛出:

Exception

storeTreeView

public com.jd.laf.web.vertx.response.Response storeTreeView(Integer brokerId,
                                                            boolean recursive)
                                                     throws Exception

broker启动信息

参数:

brokerId -

返回:

抛出:

Exception

deleteGarbageFile

public com.jd.laf.web.vertx.response.Response deleteGarbageFile(Integer brokerId,
                                                                String fileName,
                                                                boolean retain)
                                                         throws Exception

broker启动信息

参数:

brokerId -

返回:

抛出:

Exception

findBrokerMetadata

public com.jd.laf.web.vertx.response.Response findBrokerMetadata(Long brokerId,
                                                                 String topicFullName,
                                                                 Integer group)
                                                          throws Exception

TODO 改成post方法,topicFullName可能存在 broker启动信息

参数:

brokerId -

返回:

抛出:

Exception

clean

public void clean()

指定者:

clean 在接口中 com.jd.laf.web.vertx.pool.Poolable