本文整理了Java中qunar.tc.qmq.metrics.QmqCounter
类的一些代码示例,展示了QmqCounter
类的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。QmqCounter
类的具体详情如下:
包路径:qunar.tc.qmq.metrics.QmqCounter
类名称:QmqCounter
暂无
代码示例来源:origin: qunarcorp/qmq
public static void clientRefreshMetaInfoCountInc(String subject) {
Metrics.counter("clientRefreshMetaInfoCount", SUBJECT_ARRAY, new String[]{subject}).inc();
}
代码示例来源:origin: qunarcorp/qmq
public static void logSegmentTotalRefCountDec() {
Metrics.counter("logSegmentTotalRefCount", NONE, NONE).dec();
}
代码示例来源:origin: qunarcorp/qmq
public static void sendMessageTaskInvokeFailCountInc() {
Metrics.counter("sendMessageTaskInvokeFailCount").inc();
}
代码示例来源:origin: qunarcorp/qmq
private static void monitorPullCount(String subject, String group, int pullSize) {
Metrics.counter("qmq_pull_count", SUBJECT_GROUP_ARRAY, new String[]{subject, group}).inc(pullSize);
}
}
代码示例来源:origin: qunarcorp/qmq
private static void monitorGetPullOffsetError(BaseMessage message) {
LOGGER.error("lost pull offset. msgId=" + message.getMessageId());
GET_PULL_OFFSET_ERROR.inc();
}
代码示例来源:origin: qunarcorp/qmq
private static void monitorAckError(String subject, String group, int errorCode) {
LOGGER.error("ack error. subject={}, group={}, errorCode={}", subject, group, errorCode);
Metrics.counter("qmq_pull_ack_error", SUBJECT_GROUP_ARRAY, new String[]{subject, group}).inc();
}
代码示例来源:origin: qunarcorp/qmq
private static void monitorSendError(String subject, int errorCode) {
Metrics.counter("qmq_pull_send_msg_error", new String[]{"subject", "error"}, new String[]{subject, String.valueOf(errorCode)}).inc();
}
}
代码示例来源:origin: qunarcorp/qmq
public static void invalidMsgCountInc(String jdbcUrl) {
Metrics.counter("invalidMsgCount", new String[]{"jdbcUrl"}, new String[]{jdbcUrl}).inc();
}
}
代码示例来源:origin: qunarcorp/qmq
public static void subjectInfoNotFound(String subject) {
Metrics.counter("subjectInfoNotFoundCount", SUBJECT_ARRAY, new String[]{subject}).inc();
}
代码示例来源:origin: qunarcorp/qmq
public static void doElectException() {
Metrics.counter("electException").inc();
}
代码示例来源:origin: qunarcorp/qmq
public static void leaderRenewedRentTaskException() {
Metrics.counter("leaderRenewedRentTaskException").inc();
}
代码示例来源:origin: qunarcorp/qmq
public static void sendNewqmqMesssagesFailedCountInc(String subject, String jdbcUrl) {
Metrics.counter("sendNewqmqMesssagesFailedCount", new String[]{"subject", "jdbcUrl"}, new String[]{subject, jdbcUrl}).inc();
}
代码示例来源:origin: qunarcorp/qmq
private static void countInc(String name, String[] tags, String[] values, long num) {
Metrics.counter(name, tags, values).inc(num);
}
代码示例来源:origin: qunarcorp/qmq
public static void scheduleDispatch() {
Metrics.counter("scheduleDispatch", EMPTY, EMPTY).inc();
}
代码示例来源:origin: qunarcorp/qmq
public static void brokerDisconnectedCountInc(String groupName) {
Metrics.counter("brokerDisconnectedCount", new String[]{"groupName"}, new String[]{groupName}).inc();
}
代码示例来源:origin: qunarcorp/qmq
public static void initSendMessageTasksCountInc() {
Metrics.counter("initSendMessageTasksCount").inc();
}
代码示例来源:origin: qunarcorp/qmq
public static void noSendMsgCountInc(String jdbcUrl, int n) {
Metrics.counter("noSendMsgCount", new String[]{"jdbcUrl"}, new String[]{jdbcUrl}).inc(n);
}
代码示例来源:origin: qunarcorp/qmq
public static void brokerRegisterCountInc(String groupName, int requestType) {
Metrics.counter("brokerRegisterCount", new String[]{"groupName", "requestType"}, new String[]{groupName, String.valueOf(requestType)}).inc();
}
代码示例来源:origin: qunarcorp/qmq
public static void clientRegisterCountInc(String subject, int clientTypeCode) {
Metrics.counter("clientRegisterCount", new String[]{"subject", "clientTypeCode"}, new String[]{subject, String.valueOf(clientTypeCode)}).inc();
}
代码示例来源:origin: qunarcorp/qmq
public static void clientSubjectRouteCountInc(String subject) {
Metrics.counter("clientSubjectRouteCount", SUBJECT_ARRAY, new String[]{subject}).inc();
}
内容来源于网络,如有侵权,请联系作者删除!