lizhiboo opened a new issue, #245:
URL: https://github.com/apache/rocketmq-connect/issues/245
adding initAdditionalItems(List<String>
additionalItems);incAdditionalItem(String additionalItem, String key, int
incValue, int incTimes);removeAdditionalItem(String additionalItem, String key)
three methods in ConnectorStatsManager to support connector developers record
user-defined metrics.
StatsItemSet support delValue in version 4.7.1, so upgrade rocketmq.version
to 4.7.1
ConnectStatsManager.java
```java
public void initAdditionalItems(List<String> additionalItems) {
for (String additionalItem : additionalItems) {
if (this.statsTable.containsKey(additionalItem)) {
log.warn("Already exists statsItem : " + additionalItem + ",
just skip");
continue;
}
this.statsTable.put(additionalItem, new
StatsItemSet(additionalItem, scheduledExecutorService, log));
}
}
public void incAdditionalItem(String additionalItem, String key, int
incValue, int incTimes) {
StatsItemSet statsItemSet = this.statsTable.get(additionalItem);
if (statsItemSet != null) {
statsItemSet.addValue(key, incValue, incTimes);
}
}
public void removeAdditionalItem(String additionalItem, String key) {
StatsItemSet statsItemSet = this.statsTable.get(additionalItem);
if (statsItemSet != null) {
statsItemSet.delValue(key);
}
}
```
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
