com.taobao.metamorphosis.server.stats
类 StatsManager

java.lang.Object
  com.taobao.metamorphosis.server.stats.StatsManager

所有已实现的接口：

Service

public class StatsManager
extends Object
implements Service

统计管理器

作者：

boyan, wuhua

嵌套类摘要

static class

StatsManager.TopicStats

构造方法摘要

StatsManager(MetaConfig metaConfig, MessageStoreManager messageStoreManager, com.taobao.gecko.service.RemotingServer remotingServer)

方法摘要

void	dispose()
long	getCmdGetFailed()
long	getCmdGetMiss()
long	getCmdGets()
long	getCmdOffsets()
long	getCmdPutFailed()
long	getCmdPuts()
int	getCurrentConnectionCount()
int	getCurrentThreads()
String	getPid()
int	getServerPort()
long	getStartupTimestamp()
String	getStatsInfo(String item)
int	getTopicCount()
List<StatsManager.TopicStats>	getTopicsStats()
StatsManager.TopicStats	getTopicStats(String topic)
long	getTotalMessages()
long	getUpTime()
String	getVersion()
void	init()
void	statsGet(String topic, String group, int c)
void	statsGetFailed(String topic, String group, int c)
void	statsGetMiss(String topic, String group, int c)
void	statsMessageSize(String topic, int c)
void	statsOffset(String topic, String group, int c)
void	statsPut(String topic, String partition, int c)
void	statsPutFailed(String topic, String partition, int c)
void	statsRealtimePut(int c)
void	statsTxBegin(boolean isXA, int c)
void	statsTxCommit(int c)
void	statsTxRollback(int c)

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

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

构造方法详细信息

StatsManager

public StatsManager(MetaConfig metaConfig,
                    MessageStoreManager messageStoreManager,
                    com.taobao.gecko.service.RemotingServer remotingServer)

方法详细信息

getStartupTimestamp

public long getStartupTimestamp()

getStatsInfo

public String getStatsInfo(String item)

getTopicStats

public StatsManager.TopicStats getTopicStats(String topic)

getTopicsStats

public List<StatsManager.TopicStats> getTopicsStats()

getTotalMessages

public long getTotalMessages()

getTopicCount

public int getTopicCount()

getCurrentConnectionCount

public int getCurrentConnectionCount()

getCmdPuts

public long getCmdPuts()

getCmdPutFailed

public long getCmdPutFailed()

getCmdGets

public long getCmdGets()

getCmdOffsets

public long getCmdOffsets()

getCmdGetMiss

public long getCmdGetMiss()

getCmdGetFailed

public long getCmdGetFailed()

getPid

public String getPid()

getUpTime

public long getUpTime()

getVersion

public String getVersion()

getCurrentThreads

public int getCurrentThreads()

getServerPort

public int getServerPort()

statsPut

public void statsPut(String topic,
                     String partition,
                     int c)

statsRealtimePut

public void statsRealtimePut(int c)

statsGet

public void statsGet(String topic,
                     String group,
                     int c)

statsOffset

public void statsOffset(String topic,
                        String group,
                        int c)

statsGetMiss

public void statsGetMiss(String topic,
                         String group,
                         int c)

statsPutFailed

public void statsPutFailed(String topic,
                           String partition,
                           int c)

statsGetFailed

public void statsGetFailed(String topic,
                           String group,
                           int c)

statsMessageSize

public void statsMessageSize(String topic,
                             int c)

statsTxBegin

public void statsTxBegin(boolean isXA,
                         int c)

statsTxCommit

public void statsTxCommit(int c)

statsTxRollback

public void statsTxRollback(int c)

dispose

public void dispose()

指定者：

接口 Service 中的 dispose

init

public void init()

指定者：

接口 Service 中的 init