[GitHub] [rocketmq-connect] lizhiboo opened a new issue, #245: support connector-developer-defined statsitem by adding add interfaces in ConnectStatsManager

[GitBox <gi...@apache.org>]

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: dev-unsubscribe@rocketmq.apache.org.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org